THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
public interface TimeWindowedKStream<K, V> { TimeWindowedKStream<K, V> triggeremitStrategy(TriggerEmitStrategy triggerstrategy); } public interface SessionWindowedKStream<K, V> { SessionWindowedKStream<K, V> triggeremitStrategy(TriggerEmitStrategy triggerstrategy); } public interface TriggerEmitStrategy { enum TriggerTypeStrategyType { ON_WINDOW_CLOSE, // output final result ON_WINDOW_UPDATE; // output for every record } ConfigType StrategyType type(); static TriggerEmitStrategy onWindowClose() { return new WindowCloseTrigger(); } static TriggerEmitStrategy onWindowUpdate() { return new WindowUpdateTrigger(); } } public class WindowCloseTriggerWindowCloseStrategy implements TriggerEmitStrategy { WindowCloseTrigger WindowCloseStrategy() {} ConfigTypeStrategyType type() { return ON_WINDOW_CLOSE; } } |
...