Cleanup checkstyle of uc3-beam-flink

theodolite-benchmarks/uc3-beam-flink/src/main/java/application/MapTimeFormat.java

 package application;
 
-import org.apache.beam.sdk.transforms.SimpleFunction;
-import org.apache.beam.sdk.values.KV;
-import titan.ccp.model.records.ActivePowerRecord;
-
 import java.time.Instant;
 import java.time.LocalDateTime;
 import java.time.ZoneId;
+import org.apache.beam.sdk.transforms.SimpleFunction;
+import org.apache.beam.sdk.values.KV;
+import titan.ccp.model.records.ActivePowerRecord;
 
+/**
+ * Changes the time format to us europe/paris time.
+ */
 public class MapTimeFormat extends SimpleFunction<KV<String, ActivePowerRecord>, KV<HourOfDayKey,
     ActivePowerRecord>> {
-    private final ZoneId zone = ZoneId.of("Europe/Paris");
-  final StatsKeyFactory<HourOfDayKey> keyFactory = new HourOfDayKeyFactory();
+  private static final long serialVersionUID = -6597391279968647035L;
+  private final StatsKeyFactory<HourOfDayKey> keyFactory = new HourOfDayKeyFactory();
+  private final ZoneId zone = ZoneId.of("Europe/Paris");
 
-    @Override
-    public KV<application.HourOfDayKey, ActivePowerRecord> apply(
-    final KV<String, ActivePowerRecord> kv) {
-      final Instant instant = Instant.ofEpochMilli(kv.getValue().getTimestamp());
-      final LocalDateTime dateTime = LocalDateTime.ofInstant(instant, this.zone);
-      return KV.of(keyFactory.createKey(kv.getValue().getIdentifier(), dateTime),
-          kv.getValue());
-    }
+  @Override
+  public KV<application.HourOfDayKey, ActivePowerRecord> apply(
+      final KV<String, ActivePowerRecord> kv) {
+    final Instant instant = Instant.ofEpochMilli(kv.getValue().getTimestamp());
+    final LocalDateTime dateTime = LocalDateTime.ofInstant(instant, this.zone);
+    return KV.of(keyFactory.createKey(kv.getValue().getIdentifier(), dateTime),
+        kv.getValue());
   }
 }

theodolite-benchmarks/uc3-beam-flink/src/main/java/application/Uc3ApplicationBeam.java

@@ -3,12 +3,8 @@ package application;
 import com.google.common.math.Stats;
 import com.google.common.math.StatsAccumulator;
 import io.confluent.kafka.serializers.KafkaAvroDeserializer;
-import java.time.Instant;
-import java.time.LocalDateTime;
-import java.time.ZoneId;
 import java.util.HashMap;
 import java.util.Map;
-
 import org.apache.beam.runners.flink.FlinkRunner;
 import org.apache.beam.sdk.Pipeline;
 import org.apache.beam.sdk.coders.AvroCoder;