From 928a07d1ac72cda906a5ff1f36aef1aee1feea3b 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 15:39:54 +0100
Subject: [PATCH] Minor code cleanup
---
.../theodolite/benchmarks/uc1/flink/ConfigurationKeys.java | 2 --
.../theodolite/benchmarks/uc2/flink/ConfigurationKeys.java | 2 --
.../theodolite/benchmarks/uc3/flink/ConfigurationKeys.java | 2 --
.../theodolite/benchmarks/uc4/flink/ConfigurationKeys.java | 3 +--
4 files changed, 1 insertion(+), 8 deletions(-)
diff --git a/theodolite-benchmarks/uc1-flink/src/main/java/rocks/theodolite/benchmarks/uc1/flink/ConfigurationKeys.java b/theodolite-benchmarks/uc1-flink/src/main/java/rocks/theodolite/benchmarks/uc1/flink/ConfigurationKeys.java
index d2235e069..d0884f763 100644
--- a/theodolite-benchmarks/uc1-flink/src/main/java/rocks/theodolite/benchmarks/uc1/flink/ConfigurationKeys.java
+++ b/theodolite-benchmarks/uc1-flink/src/main/java/rocks/theodolite/benchmarks/uc1/flink/ConfigurationKeys.java
@@ -9,8 +9,6 @@ public final class ConfigurationKeys {
public static final String APPLICATION_VERSION = "application.version";
- public static final String COMMIT_INTERVAL_MS = "commit.interval.ms";
-
public static final String KAFKA_BOOTSTRAP_SERVERS = "kafka.bootstrap.servers";
public static final String KAFKA_INPUT_TOPIC = "kafka.input.topic";
diff --git a/theodolite-benchmarks/uc2-flink/src/main/java/rocks/theodolite/benchmarks/uc2/flink/ConfigurationKeys.java b/theodolite-benchmarks/uc2-flink/src/main/java/rocks/theodolite/benchmarks/uc2/flink/ConfigurationKeys.java
index bcb15b7d6..a2cdf8f84 100644
--- a/theodolite-benchmarks/uc2-flink/src/main/java/rocks/theodolite/benchmarks/uc2/flink/ConfigurationKeys.java
+++ b/theodolite-benchmarks/uc2-flink/src/main/java/rocks/theodolite/benchmarks/uc2/flink/ConfigurationKeys.java
@@ -17,8 +17,6 @@ public final class ConfigurationKeys {
public static final String SCHEMA_REGISTRY_URL = "schema.registry.url";
- public static final String COMMIT_INTERVAL_MS = "commit.interval.ms";
-
public static final String KAFKA_WINDOW_DURATION_MINUTES = "kafka.window.duration.minutes";
public static final String FLINK_STATE_BACKEND = "flink.state.backend";
diff --git a/theodolite-benchmarks/uc3-flink/src/main/java/rocks/theodolite/benchmarks/uc3/flink/ConfigurationKeys.java b/theodolite-benchmarks/uc3-flink/src/main/java/rocks/theodolite/benchmarks/uc3/flink/ConfigurationKeys.java
index 4f6f840c0..a19a7f8b2 100644
--- a/theodolite-benchmarks/uc3-flink/src/main/java/rocks/theodolite/benchmarks/uc3/flink/ConfigurationKeys.java
+++ b/theodolite-benchmarks/uc3-flink/src/main/java/rocks/theodolite/benchmarks/uc3/flink/ConfigurationKeys.java
@@ -24,8 +24,6 @@ public final class ConfigurationKeys {
public static final String AGGREGATION_TRIGGER_INTERVAL_SECONDS = // NOPMD
"aggregation.trigger.interval.seconds";
- public static final String COMMIT_INTERVAL_MS = "commit.interval.ms";
-
public static final String TIME_ZONE = "time.zone";
public static final String FLINK_STATE_BACKEND = "flink.state.backend";
diff --git a/theodolite-benchmarks/uc4-flink/src/main/java/rocks/theodolite/benchmarks/uc4/flink/ConfigurationKeys.java b/theodolite-benchmarks/uc4-flink/src/main/java/rocks/theodolite/benchmarks/uc4/flink/ConfigurationKeys.java
index 290f43419..6c53a7852 100644
--- a/theodolite-benchmarks/uc4-flink/src/main/java/rocks/theodolite/benchmarks/uc4/flink/ConfigurationKeys.java
+++ b/theodolite-benchmarks/uc4-flink/src/main/java/rocks/theodolite/benchmarks/uc4/flink/ConfigurationKeys.java
@@ -4,6 +4,7 @@ package rocks.theodolite.benchmarks.uc4.flink;
* Keys to access configuration parameters.
*/
public final class ConfigurationKeys {
+
public static final String APPLICATION_NAME = "application.name";
public static final String APPLICATION_VERSION = "application.version";
@@ -22,8 +23,6 @@ public final class ConfigurationKeys {
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";
--
GitLab