Page History

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;
    }
}