Interface | Description |
---|---|
MergingWindowAssigner.MergeCallback<W> |
Callback to be used in
MergingWindowAssigner.mergeWindows(Collection, MergeCallback) for specifying which
windows should be merged. |
SessionWindowTimeGapExtractor<T> |
A
SessionWindowTimeGapExtractor extracts session time gaps for Dynamic Session Window
Assigners. |
Class | Description |
---|---|
DynamicEventTimeSessionWindows<T> |
A
WindowAssigner that windows elements into sessions based on the timestamp of the
elements. |
DynamicProcessingTimeSessionWindows<T> |
A
WindowAssigner that windows elements into sessions based on the current processing
time. |
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 GlobalWindow . |
GlobalWindows.NeverTrigger |
A trigger that never fires, as default Trigger for GlobalWindows.
|
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. |
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. |
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. |
Enum | Description |
---|---|
WindowStagger |
A
WindowStagger staggers offset in runtime for each window assignment. |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.