From 2ef9f507cf1c09e187e34815ed1afe49fe190ad6 Mon Sep 17 00:00:00 2001
From: "marek.simunek" <marek.simunek@firma.seznam.cz>
Date: Tue, 13 Feb 2018 16:36:28 +0100
Subject: [PATCH] [euphoria-flink] #260 small changes

---
 .../seznam/euphoria/flink/batch/BatchFlowTranslator.java  | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/sdks/java/extensions/euphoria/euphoria-flink/src/main/java/cz/seznam/euphoria/flink/batch/BatchFlowTranslator.java b/sdks/java/extensions/euphoria/euphoria-flink/src/main/java/cz/seznam/euphoria/flink/batch/BatchFlowTranslator.java
index bde945d9..8b63f6c4 100644
--- a/sdks/java/extensions/euphoria/euphoria-flink/src/main/java/cz/seznam/euphoria/flink/batch/BatchFlowTranslator.java
+++ b/sdks/java/extensions/euphoria/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;
         }