From 1870a8757deb2c7f8dd6bda133b95cd401d6366a Mon Sep 17 00:00:00 2001
From: lorenz <stu203404@mail.uni-kiel.de>
Date: Sun, 5 Jun 2022 23:19:10 +0200
Subject: [PATCH] Adapt hazelcast ConfigurationKeys to application.properties
---
.../commons/hazelcastjet/ConfigurationKeys.java | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
diff --git a/theodolite-benchmarks/hazelcastjet-commons/src/main/java/rocks/theodolite/benchmarks/commons/hazelcastjet/ConfigurationKeys.java b/theodolite-benchmarks/hazelcastjet-commons/src/main/java/rocks/theodolite/benchmarks/commons/hazelcastjet/ConfigurationKeys.java
index c71c472e2..ce2fffc75 100644
--- a/theodolite-benchmarks/hazelcastjet-commons/src/main/java/rocks/theodolite/benchmarks/commons/hazelcastjet/ConfigurationKeys.java
+++ b/theodolite-benchmarks/hazelcastjet-commons/src/main/java/rocks/theodolite/benchmarks/commons/hazelcastjet/ConfigurationKeys.java
@@ -18,18 +18,18 @@ public class ConfigurationKeys {
public static final String KAFKA_INPUT_TOPIC = "kafka.input.topic";
// Additional topics
- public static final String KAFKA_OUTPUT_TOPIC = "KAFKA_OUTPUT_TOPIC";
+ public static final String KAFKA_OUTPUT_TOPIC = "kafka.output.topic";
// UC2
- public static final String DOWNSAMPLE_INTERVAL = "DOWNSAMPLE_INTERVAL";
+ public static final String DOWNSAMPLE_INTERVAL = "kafka.window.duration.minutes";
// UC3
- public static final String WINDOW_SIZE_IN_SECONDS = "WINDOW_SIZE_IN_SECONDS";
- public static final String HOPPING_SIZE_IN_SECONDS = "HOPPING_SIZE_IN_SECONDS";
+ public static final String AGGREGATION_DURATION_DAYS = "aggregation.duration.days";
+ public static final String AGGREGATION_ADVANCE_DAYS = "aggregation.advance.days";
// UC4
- public static final String KAFKA_CONFIGURATION_TOPIC = "KAFKA_CONFIGURATION_TOPIC";
- public static final String KAFKA_FEEDBACK_TOPIC = "KAFKA_FEEDBACK_TOPIC";
- public static final String WINDOW_SIZE_UC4 = "WINDOW_SIZE";
+ public static final String KAFKA_CONFIGURATION_TOPIC = "kafka.configuration.topic";
+ public static final String KAFKA_FEEDBACK_TOPIC = "kafka.feedback.topic";
+ public static final String WINDOW_SIZE_UC4 = "window.size";
}
--
GitLab