Package | Description |
---|---|
org.apache.flink.streaming.api.datastream | |
org.apache.flink.streaming.api.windowing.assigners | |
org.apache.flink.streaming.api.windowing.windows | |
org.apache.flink.streaming.runtime.operators.windowing |
This package contains the operators that implement the various window operations
on data streams.
|
Class and Description |
---|
WindowAssigner
A
WindowAssigner assigns zero or more Windows to an element. |
Class and Description |
---|
DynamicEventTimeSessionWindows
A
WindowAssigner that windows elements into sessions based on the timestamp of the
elements. |
DynamicProcessingTimeSessionWindows
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 . |
MergingWindowAssigner
A
WindowAssigner that can merge windows. |
MergingWindowAssigner.MergeCallback
Callback to be used in
MergingWindowAssigner.mergeWindows(Collection, MergeCallback) for specifying which
windows should be merged. |
ProcessingTimeSessionWindows
A
WindowAssigner that windows elements into sessions based on the current processing
time. |
SessionWindowTimeGapExtractor
A
SessionWindowTimeGapExtractor extracts session time gaps for Dynamic Session Window Assigners. |
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
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. |
Class and Description |
---|
MergingWindowAssigner.MergeCallback
Callback to be used in
MergingWindowAssigner.mergeWindows(Collection, MergeCallback) for specifying which
windows should be merged. |
Class and Description |
---|
MergingWindowAssigner
A
WindowAssigner that can merge windows. |
WindowAssigner
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–2020 The Apache Software Foundation. All rights reserved.