Uses of Package
org.apache.flink.streaming.runtime.operators.windowing
-
Packages that use org.apache.flink.streaming.runtime.operators.windowing Package Description org.apache.flink.streaming.api.windowing.evictors 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.runtime.operators.windowing used by org.apache.flink.streaming.api.windowing.evictors Class Description TimestampedValue Stores the value and the timestamp of the record. -
Classes in org.apache.flink.streaming.runtime.operators.windowing used by org.apache.flink.streaming.runtime.operators.windowing Class Description KeyMap A special Hash Map implementation that can be traversed efficiently in sync with other hash maps.KeyMap.Entry An entry in the hash table.KeyMap.LazyFactory A factory for lazy/on-demand instantiation of values.KeyMap.TraversalEvaluator A visitor for a traversal over the union of multiple hash maps.MergingWindowSet Utility for keeping track of mergingWindowswhen using aMergingWindowAssignerin aWindowOperator.MergingWindowSet.MergeFunction Callback forMergingWindowSet.addWindow(Window, MergeFunction).TimestampedValue Stores the value and the timestamp of the record.WindowOperator An operator that implements the logic for windowing based on aWindowAssignerandTrigger.WindowOperator.AbstractPerWindowStateStore Base class for per-windowKeyedStateStores.WindowOperator.Context Contextis a utility for handlingTriggerinvocations.WindowOperator.Timer Internal class for keeping track of in-flight timers.WindowOperator.WindowContext A utility class for handlingProcessWindowFunctioninvocations.