Interface | Description |
---|---|
InternalTimeWindowAssigner |
The internal time window assigner which has some useful methods.
|
MergingWindowAssigner.MergeCallback<W> |
Callback to be used in
MergingWindowAssigner.mergeWindows(Window, NavigableSet, MergeCallback) for
specifying which windows should be merged. |
Class | Description |
---|---|
CountSlidingWindowAssigner |
A
WindowAssigner that windows elements into sliding windows based on the count number of
the elements. |
CountTumblingWindowAssigner |
A
WindowAssigner that windows elements into fixed-size windows based on the count number
of the elements. |
CumulativeWindowAssigner |
A
WindowAssigner that windows elements into cumulative windows based on the timestamp of
the elements. |
MergingWindowAssigner<W extends Window> |
A
WindowAssigner that can merge windows. |
PanedWindowAssigner<W extends Window> |
A
WindowAssigner that window can be split into panes. |
SessionWindowAssigner |
A
WindowAssigner that windows elements into sessions based on the timestamp. |
SlidingWindowAssigner |
A
WindowAssigner that windows elements into sliding windows based on the timestamp of the
elements. |
TumblingWindowAssigner |
A
WindowAssigner that windows elements into fixed-size windows based on the timestamp of
the elements. |
WindowAssigner<W extends Window> |
A
WindowAssigner assigns zero or more Windows to an element. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.