Skip to content
Snippets Groups Projects

Draft: Add Scotty Window Processing to UC3 and allow arbitrary window configuration

Open Björn Vonheiden requested to merge stu202077/theodolite:scotty-window-processor into main
21 files
+ 300
64
Compare changes
  • Side-by-side
  • Inline
Files
21
@@ -22,19 +22,21 @@ public final class ConfigurationKeys {
@@ -22,19 +22,21 @@ 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
public static final String EMIT_PERIOD_MS = "emit.period.ms";
public static final String GRACE_PERIOD_MS = "grace.period.ms";
// UC2
 
public static final String KAFKA_WINDOW_DURATION_MINUTES = "kafka.window.duration.minutes";
// UC3
// UC3
public static final String KAFKA_WINDOW_DURATION_MINUTES = "kafka.window.duration.minutes";
public static final String AGGREGATION_DURATION = "aggregation.duration";
// UC4
public static final String AGGREGATION_ADVANCE = "aggregation.advance";
public static final String AGGREGATION_DURATION_DAYS = "aggregation.duration.days";
public static final String AGGREGATION_ADVANCE_DAYS = "aggregation.advance.days";
public static final String WINDOW_PROCESSOR = "window.processor";
 
// UC4
 
public static final String EMIT_PERIOD_MS = "emit.period.ms";
 
 
public static final String GRACE_PERIOD_MS = "grace.period.ms";
private ConfigurationKeys() {}
private ConfigurationKeys() {}
Loading