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 d2235e0693abe8f5f45899eb03bfbefec51526d5..d0884f76374ae6e63895869f3abcc1ec2fe22d6f 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 bcb15b7d655d9a05b0b65d4dda480379173a8212..a2cdf8f847886c8a1a41f14363f492d40271496b 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 4f6f840c022d99ed8609a5da528d9c5f89b6b836..a19a7f8b2660591f82f52d50deb6413e76c5e392 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 290f4341958dd133926234219017cbb9149dd3f8..6c53a78520bcb5318902adcf824fe2b80ad7b0f5 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";