Package | Description |
---|---|
org.apache.flink.streaming.api.windowing.assigners | |
org.apache.flink.streaming.runtime.operators.windowing |
This package contains the operators that implement the various window operations on data streams.
|
Modifier and Type | Method and Description |
---|---|
Collection<TimeWindow> |
TumblingProcessingTimeWindows.assignWindows(Object element,
long timestamp,
WindowAssigner.WindowAssignerContext context) |
Collection<TimeWindow> |
BaseAlignedWindowAssigner.assignWindows(Object element,
long timestamp,
WindowAssigner.WindowAssignerContext context)
Deprecated.
|
Collection<GlobalWindow> |
GlobalWindows.assignWindows(Object element,
long timestamp,
WindowAssigner.WindowAssignerContext context) |
Collection<TimeWindow> |
TumblingEventTimeWindows.assignWindows(Object element,
long timestamp,
WindowAssigner.WindowAssignerContext context) |
Collection<TimeWindow> |
SlidingProcessingTimeWindows.assignWindows(Object element,
long timestamp,
WindowAssigner.WindowAssignerContext context) |
Collection<TimeWindow> |
EventTimeSessionWindows.assignWindows(Object element,
long timestamp,
WindowAssigner.WindowAssignerContext context) |
Collection<TimeWindow> |
SlidingEventTimeWindows.assignWindows(Object element,
long timestamp,
WindowAssigner.WindowAssignerContext context) |
Collection<TimeWindow> |
ProcessingTimeSessionWindows.assignWindows(Object element,
long timestamp,
WindowAssigner.WindowAssignerContext context) |
Collection<TimeWindow> |
DynamicProcessingTimeSessionWindows.assignWindows(T element,
long timestamp,
WindowAssigner.WindowAssignerContext context) |
abstract Collection<W> |
WindowAssigner.assignWindows(T element,
long timestamp,
WindowAssigner.WindowAssignerContext context)
Returns a
Collection of windows that should be assigned to the element. |
Collection<TimeWindow> |
DynamicEventTimeSessionWindows.assignWindows(T element,
long timestamp,
WindowAssigner.WindowAssignerContext context) |
Modifier and Type | Field and Description |
---|---|
protected WindowAssigner.WindowAssignerContext |
WindowOperator.windowAssignerContext |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.