From 09b7e545756841ef721905ea253b8ae03cc967c8 Mon Sep 17 00:00:00 2001
From: lorenz <stu203404@mail.uni-kiel.de>
Date: Fri, 12 Nov 2021 16:53:27 +0100
Subject: [PATCH] Add keys from uc2-4 to beam commons ConfigurationsKeys
---
.../commons/beam/ConfigurationKeys.java | 17 +++++++++++------
1 file changed, 11 insertions(+), 6 deletions(-)
diff --git a/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/ConfigurationKeys.java b/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/ConfigurationKeys.java
index 2e60a1b4e..ab583fcd0 100644
--- a/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/ConfigurationKeys.java
+++ b/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/ConfigurationKeys.java
@@ -23,24 +23,29 @@ public final class ConfigurationKeys {
public static final String KAFKA_CONFIGURATION_TOPIC = "kafka.configuration.topic";
// UC2
- public static final String EMIT_PERIOD_MS = "emit.period.ms";
-
- public static final String GRACE_PERIOD_MS = "grace.period.ms";
-
- // UC3
public static final String KAFKA_WINDOW_DURATION_MINUTES = "kafka.window.duration.minutes";
- // UC4
+ // UC3
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 EMIT_PERIOD_MS = "emit.period.ms";
+
+ public static final String GRACE_PERIOD_MS = "grace.period.ms";
+
// BEAM
public static final String ENABLE_AUTO_COMMIT_CONFIG = "enable.auto.commit.config";
+
public static final String AUTO_OFFSET_RESET_CONFIG = "auto.offset.reset.config";
+
public static final String SPECIFIC_AVRO_READER = "specific.avro.reader";
+ private static final String TRIGGER_INTERVAL = "trigger.interval";
+
+
private ConfigurationKeys() {
}
--
GitLab