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 8fd8fbde288d1750fb1bab2147885d7be6245316..a25c0418c642f7c578647c2d87d1755736c2ab8f 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() {} }