diff --git a/theodolite-benchmarks/uc3-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc3/hazelcastjet/HistoryService.java b/theodolite-benchmarks/uc3-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc3/hazelcastjet/HistoryService.java index ecf38bd6c6a85e6d0f1431708a69f3431aff4730..a57c85cbf53c49f316a37b1cd68f340130f62f6a 100644 --- a/theodolite-benchmarks/uc3-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc3/hazelcastjet/HistoryService.java +++ b/theodolite-benchmarks/uc3-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc3/hazelcastjet/HistoryService.java @@ -22,8 +22,8 @@ public class HistoryService { private static final String KAFKA_OUTPUT_TOPIC_DEFAULT = "output"; // UC3 specific (default) - private static final String WINDOW_SIZE_IN_SECONDS_DEFAULT = "2629800"; - private static final String HOPSIZE_IN_SEC_DEFAULT = "86400"; + private static final String WINDOW_SIZE_IN_SECONDS_DEFAULT = "30"; + private static final String HOPSIZE_IN_SEC_DEFAULT = "1"; // Job name (default) private static final String JOB_NAME = "uc3-hazelcastjet"; diff --git a/theodolite-benchmarks/uc3-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc3/hazelcastjet/Uc3PipelineBuilder.java b/theodolite-benchmarks/uc3-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc3/hazelcastjet/Uc3PipelineBuilder.java index c8427de60742c2923d4ec17703592f5b8310de0c..5df6a7bb14f89a684b893600140aa094067ea983 100644 --- a/theodolite-benchmarks/uc3-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc3/hazelcastjet/Uc3PipelineBuilder.java +++ b/theodolite-benchmarks/uc3-hazelcastjet/src/main/java/rocks/theodolite/benchmarks/uc3/hazelcastjet/Uc3PipelineBuilder.java @@ -109,8 +109,8 @@ public class Uc3PipelineBuilder { // group by new keys .groupingKey(Entry::getKey) // Sliding/Hopping Window - .window(WindowDefinition.sliding(TimeUnit.SECONDS.toMillis(windowSizeInSeconds), - TimeUnit.SECONDS.toMillis(hoppingSizeInSeconds))) + .window(WindowDefinition.sliding(TimeUnit.DAYS.toMillis(windowSizeInSeconds), + TimeUnit.DAYS.toMillis(hoppingSizeInSeconds))) // get average value of group (sensoreId,hourOfDay) .aggregate( AggregateOperations.averagingDouble(record -> record.getValue().getValueInW()))