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 c71c472e262a6efe22bcdbb88127710ade572724..ce2fffc7562ca4b46dfa2403032b7de25e0b76a3 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"; }