M
- the type of input messageWK
- the type of key for the windowWV
- the type of aggregated value in the window output@InterfaceStability.Unstable public final class WindowInternal<M,WK,WV> extends java.lang.Object implements Window<M,WK,WV>
Constructor and Description |
---|
WindowInternal(Trigger<M> defaultTrigger,
java.util.function.Supplier<WV> initialValue,
FoldLeftFunction<M,WV> foldLeftFunction,
java.util.function.Function<M,WK> keyExtractor,
java.util.function.Function<M,java.lang.Long> eventTimeExtractor,
WindowType windowType) |
Modifier and Type | Method and Description |
---|---|
AccumulationMode |
getAccumulationMode() |
Trigger<M> |
getDefaultTrigger() |
Trigger<M> |
getEarlyTrigger() |
java.util.function.Function<M,java.lang.Long> |
getEventTimeExtractor() |
FoldLeftFunction<M,WV> |
getFoldLeftFunction() |
java.util.function.Supplier<WV> |
getInitializer() |
java.util.function.Function<M,WK> |
getKeyExtractor() |
Trigger<M> |
getLateTrigger() |
WindowType |
getWindowType() |
Window<M,WK,WV> |
setAccumulationMode(AccumulationMode mode)
Specify how a
Window should process its previously emitted WindowPane s. |
Window<M,WK,WV> |
setEarlyTrigger(Trigger<M> trigger)
Set the early triggers for this
Window . |
Window<M,WK,WV> |
setLateTrigger(Trigger<M> trigger)
Set the late triggers for this
Window . |
public WindowInternal(Trigger<M> defaultTrigger, java.util.function.Supplier<WV> initialValue, FoldLeftFunction<M,WV> foldLeftFunction, java.util.function.Function<M,WK> keyExtractor, java.util.function.Function<M,java.lang.Long> eventTimeExtractor, WindowType windowType)
public Window<M,WK,WV> setEarlyTrigger(Trigger<M> trigger)
Window
public Window<M,WK,WV> setLateTrigger(Trigger<M> trigger)
Window
public Window<M,WK,WV> setAccumulationMode(AccumulationMode mode)
Window
Window
should process its previously emitted WindowPane
s.
There are two types of AccumulationMode
s:
setAccumulationMode
in interface Window<M,WK,WV>
mode
- the accumulation modeWindow
function with mode
set as its AccumulationMode
.public java.util.function.Supplier<WV> getInitializer()
public FoldLeftFunction<M,WV> getFoldLeftFunction()
public java.util.function.Function<M,java.lang.Long> getEventTimeExtractor()
public WindowType getWindowType()
public AccumulationMode getAccumulationMode()