From be57e2b677e49b2009a8cdfcb6f0419768941572 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:30:07 +0100
Subject: [PATCH] Minor refactorings
---
.../theodolite/benchmarks/uc4/beam/PipelineFactory.java | 6 +++---
.../src/main/resources/META-INF/application.properties | 2 +-
2 files changed, 4 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 e065993b5..8ea7a8d3e 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
@@ -72,11 +72,11 @@ public class PipelineFactory extends AbstractPipelineFactory {
final String configurationTopic =
this.config.getString(ConfigurationKeys.KAFKA_CONFIGURATION_TOPIC);
- final Duration duration = Duration.standardSeconds(
- this.config.getInt(ConfigurationKeys.EMIT_PERIOD_SECONDS));
+ final Duration duration = Duration.millis(
+ this.config.getInt(ConfigurationKeys.EMIT_PERIOD_MS));
final Duration triggerDelay = Duration.standardSeconds(
this.config.getInt(ConfigurationKeys.TRIGGER_INTERVAL_SECONDS));
- final Duration gracePeriod = Duration.standardSeconds(
+ final Duration gracePeriod = Duration.standardSeconds( // TODO this is wrong
this.config.getInt(ConfigurationKeys.GRACE_PERIOD_MS));
// Read from Kafka
diff --git a/theodolite-benchmarks/uc4-beam/src/main/resources/META-INF/application.properties b/theodolite-benchmarks/uc4-beam/src/main/resources/META-INF/application.properties
index 633b5084d..a5dc4cfac 100644
--- a/theodolite-benchmarks/uc4-beam/src/main/resources/META-INF/application.properties
+++ b/theodolite-benchmarks/uc4-beam/src/main/resources/META-INF/application.properties
@@ -9,7 +9,7 @@ kafka.feedback.topic=aggregation-feedback
schema.registry.url=http://localhost:8081
-kafka.window.duration.minutes=1
+emit.period.ms=5000
trigger.interval=15
grace.period.ms=270
--
GitLab