From 0babb6b38babc4189a8d29a5990b9560144bb663 Mon Sep 17 00:00:00 2001
From: lorenz <stu203404@mail.uni-kiel.de>
Date: Mon, 9 May 2022 20:09:09 +0200
Subject: [PATCH] Extend common ConfigurationKeys
---
.../commons/flink/ConfigurationKeys.java | 25 ++++++++++++++++++-
1 file changed, 24 insertions(+), 1 deletion(-)
diff --git a/theodolite-benchmarks/flink-commons/src/main/java/rocks/theodolite/benchmarks/commons/flink/ConfigurationKeys.java b/theodolite-benchmarks/flink-commons/src/main/java/rocks/theodolite/benchmarks/commons/flink/ConfigurationKeys.java
index 8fd8fbde2..a25c0418c 100644
--- a/theodolite-benchmarks/flink-commons/src/main/java/rocks/theodolite/benchmarks/commons/flink/ConfigurationKeys.java
+++ b/theodolite-benchmarks/flink-commons/src/main/java/rocks/theodolite/benchmarks/commons/flink/ConfigurationKeys.java
@@ -5,6 +5,26 @@ package rocks.theodolite.benchmarks.commons.flink;
*/
public final class ConfigurationKeys {
+ public static final String APPLICATION_NAME = "application.name";
+
+ public static final String APPLICATION_VERSION = "application.version";
+
+ public static final String CONFIGURATION_KAFKA_TOPIC = "configuration.kafka.topic";
+
+ public static final String KAFKA_BOOTSTRAP_SERVERS = "kafka.bootstrap.servers";
+
+ public static final String KAFKA_OUTPUT_TOPIC = "kafka.output.topic";
+
+ public static final String KAFKA_INPUT_TOPIC = "kafka.input.topic";
+
+ public static final String SCHEMA_REGISTRY_URL = "schema.registry.url";
+
+ public static final String WINDOW_SIZE_MS = "window.size.ms";
+
+ public static final String WINDOW_GRACE_MS = "window.grace.ms";
+
+ public static final String COMMIT_INTERVAL_MS = "commit.interval.ms";
+
public static final String FLINK_STATE_BACKEND = "flink.state.backend";
public static final String FLINK_STATE_BACKEND_PATH = "flink.state.backend.path";
@@ -12,8 +32,11 @@ public final class ConfigurationKeys {
public static final String FLINK_STATE_BACKEND_MEMORY_SIZE = // NOPMD
"flink.state.backend.memory.size";
- public static final String FLINK_CHECKPOINTING = "checkpointing";
+ public static final String DEBUG = "debug";
+
+ public static final String CHECKPOINTING = "checkpointing";
+ public static final String PARALLELISM = "parallelism";
private ConfigurationKeys() {}
}
--
GitLab