Uses of Interface
org.apache.flink.table.runtime.generated.RecordEqualiser
-
Packages that use RecordEqualiser Package Description org.apache.flink.table.runtime.operators.window.groupwindow.operator -
-
Uses of RecordEqualiser in org.apache.flink.table.runtime.operators.window.groupwindow.operator
Fields in org.apache.flink.table.runtime.operators.window.groupwindow.operator 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.groupwindow.operator 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.groupwindow.operator with parameters of type RecordEqualiser Constructor Description AggregateWindowOperatorBuilder(NamespaceAggsHandleFunction<?> aggregateFunction, RecordEqualiser equaliser, WindowOperatorBuilder windowOperatorBuilder)
-