IN - The type of the incoming elements.ACC - The type of elements stored in the window buffers.OUT - The type of elements emitted by the WindowFunction.W - The type of Window that the WindowAssigner assigns.@Internal public class EvictingNonKeyedWindowOperator<IN,ACC,OUT,W extends Window> extends NonKeyedWindowOperator<IN,ACC,OUT,W>
EvictingWindowOperator,
Serialized FormNonKeyedWindowOperator.ContextcurrentWatermark, timestampedCollector, windowsuserFunctionchainingStrategy, output| Constructor and Description |
|---|
EvictingNonKeyedWindowOperator(WindowAssigner<? super IN,W> windowAssigner,
TypeSerializer<W> windowSerializer,
WindowBufferFactory<? super IN,ACC,? extends EvictingWindowBuffer<IN,ACC>> windowBufferFactory,
AllWindowFunction<ACC,OUT,W> windowFunction,
Trigger<? super IN,? super W> trigger,
Evictor<? super IN,? super W> evictor) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
emitWindow(NonKeyedWindowOperator.Context context) |
Evictor<? super IN,? super W> |
getEvictor() |
dispose, getTrigger, getWindowAssigner, getWindowBufferFactory, open, processElement, processWatermark, restoreState, setInputType, snapshotOperatorState, triggerclose, getUserFunction, getUserFunctionParameters, notifyOfCompletedCheckpoint, setOutputType, setupdisableInputCopy, getChainingStrategy, getContainingTask, getExecutionConfig, getOperatorConfig, getPartitionedState, getPartitionedState, getRuntimeContext, getStateBackend, getUserCodeClassloader, isInputCopyingDisabled, registerTimer, setChainingStrategy, setKeyContext, setKeyContextElement1, setKeyContextElement2clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitclose, getChainingStrategy, isInputCopyingDisabled, notifyOfCompletedCheckpoint, setChainingStrategy, setKeyContextElement1, setKeyContextElement2, setuppublic EvictingNonKeyedWindowOperator(WindowAssigner<? super IN,W> windowAssigner, TypeSerializer<W> windowSerializer, WindowBufferFactory<? super IN,ACC,? extends EvictingWindowBuffer<IN,ACC>> windowBufferFactory, AllWindowFunction<ACC,OUT,W> windowFunction, Trigger<? super IN,? super W> trigger, Evictor<? super IN,? super W> evictor)
protected void emitWindow(NonKeyedWindowOperator.Context context) throws Exception
emitWindow in class NonKeyedWindowOperator<IN,ACC,OUT,W extends Window>ExceptionCopyright © 2014–2017 The Apache Software Foundation. All rights reserved.