Uses of Interface
org.apache.flink.table.runtime.generated.RecordEqualiser
-
Packages that use RecordEqualiser Package Description org.apache.flink.table.runtime.operators.window -
-
Uses of RecordEqualiser in org.apache.flink.table.runtime.operators.window
Fields in org.apache.flink.table.runtime.operators.window declared as RecordEqualiser Modifier and Type Field Description protected RecordEqualiserAggregateWindowOperator. equaliserThe util to compare two RowData equals to each other.Methods in org.apache.flink.table.runtime.operators.window with parameters of type RecordEqualiser Modifier and Type Method Description WindowOperatorBuilder.AggregateWindowOperatorBuilderWindowOperatorBuilder. aggregate(NamespaceAggsHandleFunction<?> aggregateFunction, RecordEqualiser equaliser, org.apache.flink.table.types.logical.LogicalType[] accumulatorTypes, org.apache.flink.table.types.logical.LogicalType[] aggResultTypes, org.apache.flink.table.types.logical.LogicalType[] windowPropertyTypes)Constructors in org.apache.flink.table.runtime.operators.window with parameters of type RecordEqualiser Constructor Description AggregateWindowOperatorBuilder(NamespaceAggsHandleFunction<?> aggregateFunction, RecordEqualiser equaliser, WindowOperatorBuilder windowOperatorBuilder)
-