[beam] 01/12: Make parameter of DoFnRunners.lateDataDroppingRunner() more specific

[aljoscha]

This is an automated email from the ASF dual-hosted git repository.

aljoscha pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 50c6d9316c8c5089065dd291b097e06b0c80980e
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
AuthorDate: Thu Jan 11 10:56:49 2018 +0100

    Make parameter of DoFnRunners.lateDataDroppingRunner() more specific
---
 .../src/main/java/org/apache/beam/runners/core/DoFnRunners.java       | 4 ++--
 .../runners/flink/translation/wrappers/streaming/DoFnOperator.java    | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/runners/core-java/src/main/java/org/apache/beam/runners/core/DoFnRunners.java 
b/runners/core-java/src/main/java/org/apache/beam/runners/core/DoFnRunners.java
index 9d3e25d..80c830a 100644
--- 
a/runners/core-java/src/main/java/org/apache/beam/runners/core/DoFnRunners.java
+++ 
b/runners/core-java/src/main/java/org/apache/beam/runners/core/DoFnRunners.java
@@ -80,12 +80,12 @@ public class DoFnRunners {
   public static <K, InputT, OutputT, W extends BoundedWindow>
       DoFnRunner<KeyedWorkItem<K, InputT>, KV<K, OutputT>> 
lateDataDroppingRunner(
           DoFnRunner<KeyedWorkItem<K, InputT>, KV<K, OutputT>> wrappedRunner,
-          StepContext stepContext,
+          TimerInternals timerInternals,
           WindowingStrategy<?, W> windowingStrategy) {
     return new LateDataDroppingDoFnRunner<>(
         wrappedRunner,
         windowingStrategy,
-        stepContext.timerInternals());
+        timerInternals);
   }
 
   /**
diff --git 
a/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java
 
b/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java
index 41a35ce..8ccbd8f 100644
--- 
a/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java
+++ 
b/runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java
@@ -314,7 +314,7 @@ public class DoFnOperator<InputT, OutputT>
 
       doFnRunner = DoFnRunners.lateDataDroppingRunner(
           (DoFnRunner) doFnRunner,
-          stepContext,
+          timerInternals,
           windowingStrategy);
     } else if (keyCoder != null) {
       // It is a stateful DoFn

-- 
To stop receiving notification emails like this one, please contact
aljos...@apache.org.