@PublicEvolving public final class TumblingAlignedProcessingTimeWindows extends BaseAlignedWindowAssigner
Prior Flink versions used that operator automatically for simple processing time windows (tumbling and sliding) when no custom trigger and no evictor was specified. In the current Flink version, that operator is only used when programs explicitly specify this window assigner. This is only intended for special cases where programs relied on the better performance of the fast aligned window operator, and are willing to accept the lack of support for various features as indicated below:
Future implementation plans: We plan to add some of the optimizations used by this operator to the general window operator, so that future versions of Flink will not have the performance/functionality trade-off any more.
Note on implementation: The concrete operator instantiated by this assigner is either the
AggregatingProcessingTimeWindowOperator
or AccumulatingProcessingTimeWindowOperator
.
WindowAssigner.WindowAssignerContext
Constructor and Description |
---|
TumblingAlignedProcessingTimeWindows(long size) |
Modifier and Type | Method and Description |
---|---|
static TumblingAlignedProcessingTimeWindows |
of(Time size)
Creates a new
TumblingAlignedProcessingTimeWindows WindowAssigner that assigns
elements to time windows based on the element timestamp. |
assignWindows, getDefaultTrigger, getSize, getWindowSerializer, isEventTime
public TumblingAlignedProcessingTimeWindows(long size)
public static TumblingAlignedProcessingTimeWindows of(Time size)
TumblingAlignedProcessingTimeWindows
WindowAssigner
that assigns
elements to time windows based on the element timestamp.size
- The size of the generated windows.Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.