diff --git a/theodolite-benchmarks/uc4-beam/src/main/java/rocks/theodolite/benchmarks/uc4/beam/PipelineFactory.java b/theodolite-benchmarks/uc4-beam/src/main/java/rocks/theodolite/benchmarks/uc4/beam/PipelineFactory.java index 8ea7a8d3e7a49ad889984849fdc3b3700b8bc096..633fd9d744f27badbfeccb26b8a6f8409ba562ef 100644 --- a/theodolite-benchmarks/uc4-beam/src/main/java/rocks/theodolite/benchmarks/uc4/beam/PipelineFactory.java +++ b/theodolite-benchmarks/uc4-beam/src/main/java/rocks/theodolite/benchmarks/uc4/beam/PipelineFactory.java @@ -115,9 +115,11 @@ public class PipelineFactory extends AbstractPipelineFactory { .apply("Read Windows", Window.into(FixedWindows.of(duration))) .apply("Set trigger for input", Window .<KV<String, ActivePowerRecord>>configure() - .triggering(Repeatedly.forever( - AfterProcessingTime.pastFirstElementInPane() - .plusDelayOf(triggerDelay))) + .triggering(Repeatedly + .forever( + AfterProcessingTime + .pastFirstElementInPane() + .plusDelayOf(triggerDelay))) .withAllowedLateness(gracePeriod) .discardingFiredPanes()); @@ -204,7 +206,8 @@ public class PipelineFactory extends AbstractPipelineFactory { .apply("Reset trigger for aggregations", Window .<KV<String, ActivePowerRecord>>configure() .triggering(Repeatedly.forever( - AfterProcessingTime.pastFirstElementInPane() + AfterProcessingTime + .pastFirstElementInPane() .plusDelayOf(triggerDelay))) .withAllowedLateness(gracePeriod) .discardingFiredPanes())