Package | Description |
---|---|
org.apache.flink.table.runtime.operators.window | |
org.apache.flink.table.runtime.operators.window.internal |
Modifier and Type | Method and Description |
---|---|
WindowOperatorBuilder |
WindowOperatorBuilder.aggregate(NamespaceAggsHandleFunction<?> aggregateFunction,
RecordEqualiser equaliser,
LogicalType[] accumulatorTypes,
LogicalType[] aggResultTypes,
LogicalType[] windowPropertyTypes) |
Modifier and Type | Field and Description |
---|---|
protected NamespaceAggsHandleFunction<W> |
InternalWindowProcessFunction.windowAggregator |
Constructor and Description |
---|
GeneralWindowProcessFunction(WindowAssigner<W> windowAssigner,
NamespaceAggsHandleFunction<W> windowAggregator,
long allowedLateness) |
InternalWindowProcessFunction(WindowAssigner<W> windowAssigner,
NamespaceAggsHandleFunction<W> windowAggregator,
long allowedLateness) |
MergingWindowProcessFunction(MergingWindowAssigner<W> windowAssigner,
NamespaceAggsHandleFunction<W> windowAggregator,
TypeSerializer<W> windowSerializer,
long allowedLateness) |
PanedWindowProcessFunction(PanedWindowAssigner<W> windowAssigner,
NamespaceAggsHandleFunction<W> windowAggregator,
long allowedLateness) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.