[euphoria-flink] #260 small changes

seznam · Feb 13, 2018 · 2ef9f50 · 2ef9f50
1 parent f84b9b8
commit 2ef9f50
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...oria/euphoria-flink/src/main/java/cz/seznam/euphoria/flink/batch/BatchFlowTranslator.java b/...oria/euphoria-flink/src/main/java/cz/seznam/euphoria/flink/batch/BatchFlowTranslator.java
@@ -101,8 +101,8 @@ public BatchFlowTranslator(Settings settings,
     this.accumulatorFactory = Objects.requireNonNull(accumulatorFactory);
 
     // basic operators
-    Translation.add(translations, FlowUnfolder.InputOperator.class, new InputTranslator
-        (splitAssignerFactory));
+    Translation.add(translations, FlowUnfolder.InputOperator.class, new InputTranslator(
+        splitAssignerFactory));
     Translation.add(translations, FlatMap.class, new FlatMapTranslator());
     Translation.add(translations, ReduceStateByKey.class, new ReduceStateByKeyTranslator());
     Translation.add(translations, Union.class, new UnionTranslator());
@@ -158,8 +158,8 @@ public List<DataSink<?>> translateInto(Flow flow) {
       }
       // ~ verify the flowToDag translation
       Translation<Operator<?, ?>> firstMatch = null;
-      for (Translation tx : txs) {
-        if (tx.accept == null || (boolean)tx.accept.apply(originalOp)) {
+      for (Translation<Operator<?, ?>> tx : txs) {
+        if (tx.accept == null || tx.accept.apply(originalOp)) {
           firstMatch = tx;
           break;
         }