#14 [euphoria-flink] Allow WindowAssigner operator chaining

seznam · Mar 24, 2017 · 29538db · 29538db
1 parent ed1b514
commit 29538db
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...ia-flink/src/main/java/cz/seznam/euphoria/flink/streaming/ReduceStateByKeyTranslator.java b/...ia-flink/src/main/java/cz/seznam/euphoria/flink/streaming/ReduceStateByKeyTranslator.java
@@ -37,6 +37,7 @@
 import org.apache.flink.streaming.api.datastream.DataStream;
 import org.apache.flink.streaming.api.functions.timestamps.BoundedOutOfOrdernessTimestampExtractor;
 import org.apache.flink.streaming.api.operators.AbstractStreamOperator;
+import org.apache.flink.streaming.api.operators.ChainingStrategy;
 import org.apache.flink.streaming.api.operators.OneInputStreamOperator;
 import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;
 
@@ -149,6 +150,9 @@ private static class WindowAssignerOperator
 
     private WindowAssignerOperator(WindowAssigner windowAssigner) {
       this.windowAssigner = windowAssigner;
+
+      // allow chaining to optimize performance
+      this.chainingStrategy = ChainingStrategy.ALWAYS;
     }
 
     @Override