From 59d9d75577852559bc09f16ae35aba0b4f033b61 Mon Sep 17 00:00:00 2001
From: lorenz <stu203404@mail.uni-kiel.de>
Date: Sun, 5 Jun 2022 22:47:45 +0200
Subject: [PATCH] Align uc3 to the other impls to use days instead of seconds
---
.../benchmarks/uc3/hazelcastjet/HistoryService.java | 4 ++--
.../benchmarks/uc3/hazelcastjet/Uc3PipelineBuilder.java | 4 ++--
2 files changed, 4 insertions(+), 4 deletions(-)
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 ecf38bd6c..a57c85cbf 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 c8427de60..5df6a7bb1 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()))
--
GitLab