Enhanced beam-commons for uc3

theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/ConfigurationKeys.java

@@ -46,6 +46,8 @@ public final class ConfigurationKeys {
   public static final String TRIGGER_INTERVAL  = "trigger.interval";
 
 
+
+
   private ConfigurationKeys() {
   }
 

theodolite-benchmarks/uc3-beam-flink/src/main/java/application/EventTimePolicy.java → theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/kafka/EventTimePolicy.java

-package application;
+package theodolite.commons.beam.kafka;
 
 import java.util.Optional;
 

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

@@ -76,6 +76,7 @@ public final class Uc3ApplicationBeam {
         System.getenv(AGGREGATION_ADVANCE_DAYS) == null
             ? "1" : System.getenv(AGGREGATION_ADVANCE_DAYS));
     final Duration advance = Duration.standardDays(aggregationAdvance);
+
     final int triggerInterval = Integer.parseInt(
         System.getenv(TRIGGER_INTERVAL) == null
             ? "15" : System.getenv(TRIGGER_INTERVAL));