From 09cd27d8e7efa2c6a85032d3b4516eb45a286a50 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?S=C3=B6ren=20Henning?= <soeren.henning@email.uni-kiel.de>
Date: Sat, 26 Nov 2022 18:33:53 +0100
Subject: [PATCH] Improve code style
---
.../benchmarks/uc4/beam/PipelineFactory.java | 11 +++++++----
1 file changed, 7 insertions(+), 4 deletions(-)
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 8ea7a8d3e..633fd9d74 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())
--
GitLab