Package | Description |
---|---|
org.apache.flink.table.runtime.operators.window |
Modifier and Type | Field and Description |
---|---|
protected RecordEqualiser |
AggregateWindowOperator.equaliser
The util to compare two RowData equals to each other.
|
Modifier and Type | Method and Description |
---|---|
WindowOperatorBuilder.AggregateWindowOperatorBuilder |
WindowOperatorBuilder.aggregate(NamespaceAggsHandleFunction<?> aggregateFunction,
RecordEqualiser equaliser,
LogicalType[] accumulatorTypes,
LogicalType[] aggResultTypes,
LogicalType[] windowPropertyTypes) |
Constructor and Description |
---|
AggregateWindowOperatorBuilder(NamespaceAggsHandleFunction<?> aggregateFunction,
RecordEqualiser equaliser,
WindowOperatorBuilder windowOperatorBuilder) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.