Uses of Class
org.apache.flink.table.runtime.generated.GeneratedRecordEqualiser

Packages that use GeneratedRecordEqualiser

Package	Description
org.apache.flink.table.runtime.operators.aggregate
org.apache.flink.table.runtime.operators.deduplicate
org.apache.flink.table.runtime.operators.rank
org.apache.flink.table.runtime.operators.sink
org.apache.flink.table.runtime.operators.window

Uses of GeneratedRecordEqualiser in org.apache.flink.table.runtime.operators.aggregate

Constructors in org.apache.flink.table.runtime.operators.aggregate with parameters of type GeneratedRecordEqualiser

Constructor and Description
GroupAggFunction(GeneratedAggsHandleFunction genAggsHandler, GeneratedRecordEqualiser genRecordEqualiser, LogicalType[] accTypes, int indexOfCountStar, boolean generateUpdateBefore, long stateRetentionTime) Creates a GroupAggFunction.
MiniBatchGlobalGroupAggFunction(GeneratedAggsHandleFunction genLocalAggsHandler, GeneratedAggsHandleFunction genGlobalAggsHandler, GeneratedRecordEqualiser genRecordEqualiser, LogicalType[] accTypes, int indexOfCountStar, boolean generateUpdateBefore, long stateRetentionTime) Creates a MiniBatchGlobalGroupAggFunction.
MiniBatchGroupAggFunction(GeneratedAggsHandleFunction genAggsHandler, GeneratedRecordEqualiser genRecordEqualiser, LogicalType[] accTypes, RowType inputType, int indexOfCountStar, boolean generateUpdateBefore, long stateRetentionTime) Creates a MiniBatchGroupAggFunction.

Uses of GeneratedRecordEqualiser in org.apache.flink.table.runtime.operators.deduplicate

Constructors in org.apache.flink.table.runtime.operators.deduplicate with parameters of type GeneratedRecordEqualiser

Constructor and Description
ProcTimeDeduplicateKeepLastRowFunction(InternalTypeInfo<RowData> typeInfo, long stateRetentionTime, boolean generateUpdateBefore, boolean generateInsert, boolean inputInsertOnly, GeneratedRecordEqualiser genRecordEqualiser)
ProcTimeMiniBatchDeduplicateKeepLastRowFunction(InternalTypeInfo<RowData> typeInfo, TypeSerializer<RowData> serializer, long stateRetentionTime, boolean generateUpdateBefore, boolean generateInsert, boolean inputInsertOnly, GeneratedRecordEqualiser genRecordEqualiser)

Uses of GeneratedRecordEqualiser in org.apache.flink.table.runtime.operators.rank

Constructors in org.apache.flink.table.runtime.operators.rank with parameters of type GeneratedRecordEqualiser

Constructor and Description
RetractableTopNFunction(StateTtlConfig ttlConfig, InternalTypeInfo<RowData> inputRowType, ComparableRecordComparator comparableRecordComparator, RowDataKeySelector sortKeySelector, RankType rankType, RankRange rankRange, GeneratedRecordEqualiser generatedEqualiser, boolean generateUpdateBefore, boolean outputRankNumber)

Uses of GeneratedRecordEqualiser in org.apache.flink.table.runtime.operators.sink

Constructors in org.apache.flink.table.runtime.operators.sink with parameters of type GeneratedRecordEqualiser

Constructor and Description
SinkUpsertMaterializer(StateTtlConfig ttlConfig, TypeSerializer<RowData> serializer, GeneratedRecordEqualiser generatedRecordEqualiser, GeneratedRecordEqualiser generatedUpsertKeyEqualiser, int[] inputUpsertKey)

Uses of GeneratedRecordEqualiser in org.apache.flink.table.runtime.operators.window

Methods in org.apache.flink.table.runtime.operators.window with parameters of type GeneratedRecordEqualiser

Modifier and Type	Method and Description
WindowOperatorBuilder.AggregateWindowOperatorBuilder	WindowOperatorBuilder.aggregate(GeneratedNamespaceAggsHandleFunction<?> generatedAggregateFunction, GeneratedRecordEqualiser generatedEqualiser, LogicalType[] accumulatorTypes, LogicalType[] aggResultTypes, LogicalType[] windowPropertyTypes)

Constructors in org.apache.flink.table.runtime.operators.window with parameters of type GeneratedRecordEqualiser

Constructor and Description
AggregateWindowOperatorBuilder(GeneratedNamespaceAggsHandleFunction<?> generatedAggregateFunction, GeneratedRecordEqualiser generatedEqualiser, WindowOperatorBuilder windowOperatorBuilder)