Skip to content
Snippets Groups Projects
Commit 09b7e545 authored by Lorenz Boguhn's avatar Lorenz Boguhn Committed by Lorenz Boguhn
Browse files

Add keys from uc2-4 to beam commons ConfigurationsKeys

parent 908757e2
No related branches found
No related tags found
1 merge request!187Migrate Beam benchmark implementation
...@@ -23,24 +23,29 @@ public final class ConfigurationKeys { ...@@ -23,24 +23,29 @@ public final class ConfigurationKeys {
public static final String KAFKA_CONFIGURATION_TOPIC = "kafka.configuration.topic"; public static final String KAFKA_CONFIGURATION_TOPIC = "kafka.configuration.topic";
// UC2 // 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"; 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_DURATION_DAYS = "aggregation.duration.days";
public static final String AGGREGATION_ADVANCE_DAYS = "aggregation.advance.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 // BEAM
public static final String ENABLE_AUTO_COMMIT_CONFIG = "enable.auto.commit.config"; 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 AUTO_OFFSET_RESET_CONFIG = "auto.offset.reset.config";
public static final String SPECIFIC_AVRO_READER = "specific.avro.reader"; public static final String SPECIFIC_AVRO_READER = "specific.avro.reader";
private static final String TRIGGER_INTERVAL = "trigger.interval";
private ConfigurationKeys() { private ConfigurationKeys() {
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment