Interface | Description |
---|---|
MergingWindowAssigner.MergeCallback<W> |
Callback to be used in
MergingWindowAssigner.mergeWindows(Collection, MergeCallback) for specifying which
windows should be merged. |
Class | Description |
---|---|
EventTimeSessionWindows |
A
WindowAssigner that windows elements into sessions based on the timestamp of the
elements. |
GlobalWindows |
A
WindowAssigner that assigns all elements to the same global window. |
MergingWindowAssigner<T,W extends Window> |
A
WindowAssigner that can merge windows. |
ProcessingTimeSessionWindows |
A
WindowAssigner that windows elements into sessions based on the current processing
time. |
SlidingEventTimeWindows |
A
WindowAssigner that windows elements into sliding windows based on the timestamp of the
elements. |
SlidingProcessingTimeWindows |
A
WindowAssigner that windows elements into sliding windows based on the current
system time of the machine the operation is running on. |
SlidingTimeWindows | Deprecated
Please use
SlidingEventTimeWindows . |
TumblingEventTimeWindows |
A
WindowAssigner that windows elements into windows based on the timestamp of the
elements. |
TumblingProcessingTimeWindows |
A
WindowAssigner that windows elements into windows based on the current
system time of the machine the operation is running on. |
TumblingTimeWindows | Deprecated
Please use
TumblingEventTimeWindows . |
WindowAssigner<T,W extends Window> |
A
WindowAssigner assigns zero or more Windows to an element. |
WindowAssigner.WindowAssignerContext |
A context provided to the
WindowAssigner that allows it to query the
current processing time. |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.