...beam-samza/src/main/java/application/EventTimePolicy.java

...c/main/java/application/Uc4ApplicationBeamNoFeedback.java

...c4-beam-samza/src/main/java/application/Uc4BeamSamza.java

...-samza/src/main/resources/META-INF/application.properties

theodolite-benchmarks/uc4-beam/build.gradle

...plication/AggregatedActivePowerRecordEventTimePolicy.java

...c4-beam/src/main/java/application/AggregatedToActive.java

...c4-beam/src/main/java/application/DuplicateAsFlatMap.java

...arks/uc4-beam/src/main/java/application/FilterEvents.java

.../uc4-beam/src/main/java/application/FilterNullValues.java

...uc4-beam/src/main/java/application/GenerateParentsFn.java

...uc4-beam/src/main/java/application/RecordAggregation.java

...s/uc4-beam/src/main/java/application/SensorParentKey.java

...c4-beam/src/main/java/application/SetIdForAggregated.java

...rks/uc4-beam/src/main/java/application/SetKeyToGroup.java

...s/uc4-beam/src/main/java/application/Uc4BeamPipeline.java

...eam/src/main/java/application/UpdateChildParentPairs.java

.../java/serialization/AggregatedActivePowerRecordCoder.java

...erialization/AggregatedActivePowerRecordDeserializer.java

.../serialization/AggregatedActivePowerRecordSerializer.java