Uses of Package
org.apache.flink.streaming.api.windowing.assigners
-
Packages that use org.apache.flink.streaming.api.windowing.assigners 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. -
Classes in org.apache.flink.streaming.api.windowing.assigners used by org.apache.flink.streaming.api.datastream Class Description WindowAssigner AWindowAssignerassigns zero or moreWindowsto an element. -
Classes in org.apache.flink.streaming.api.windowing.assigners used by org.apache.flink.streaming.api.windowing.assigners Class Description DynamicEventTimeSessionWindows AWindowAssignerthat windows elements into sessions based on the timestamp of the elements.DynamicProcessingTimeSessionWindows AWindowAssignerthat windows elements into sessions based on the current processing time.EventTimeSessionWindows AWindowAssignerthat windows elements into sessions based on the timestamp of the elements.GlobalWindows AWindowAssignerthat assigns all elements to the sameGlobalWindow.MergingWindowAssigner AWindowAssignerthat can merge windows.MergingWindowAssigner.MergeCallback Callback to be used inMergingWindowAssigner.mergeWindows(Collection, MergeCallback)for specifying which windows should be merged.ProcessingTimeSessionWindows AWindowAssignerthat windows elements into sessions based on the current processing time.SessionWindowTimeGapExtractor ASessionWindowTimeGapExtractorextracts session time gaps for Dynamic Session Window Assigners.SlidingEventTimeWindows AWindowAssignerthat windows elements into sliding windows based on the timestamp of the elements.SlidingProcessingTimeWindows AWindowAssignerthat windows elements into sliding windows based on the current system time of the machine the operation is running on.TumblingEventTimeWindows AWindowAssignerthat windows elements into windows based on the timestamp of the elements.TumblingProcessingTimeWindows AWindowAssignerthat windows elements into windows based on the current system time of the machine the operation is running on.WindowAssigner AWindowAssignerassigns zero or moreWindowsto an element.WindowAssigner.WindowAssignerContext A context provided to theWindowAssignerthat allows it to query the current processing time.WindowStagger AWindowStaggerstaggers offset in runtime for each window assignment. -
Classes in org.apache.flink.streaming.api.windowing.assigners used by org.apache.flink.streaming.api.windowing.windows Class Description MergingWindowAssigner.MergeCallback Callback to be used inMergingWindowAssigner.mergeWindows(Collection, MergeCallback)for specifying which windows should be merged. -
Classes in org.apache.flink.streaming.api.windowing.assigners used by org.apache.flink.streaming.runtime.operators.windowing Class Description MergingWindowAssigner AWindowAssignerthat can merge windows.WindowAssigner AWindowAssignerassigns zero or moreWindowsto an element.WindowAssigner.WindowAssignerContext A context provided to theWindowAssignerthat allows it to query the current processing time.