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	Description
GroupAggFunction(GeneratedAggsHandleFunction genAggsHandler, GeneratedRecordEqualiser genRecordEqualiser, org.apache.flink.table.types.logical.LogicalType[] accTypes, int indexOfCountStar, boolean generateUpdateBefore, long stateRetentionTime)	Creates a GroupAggFunction.
MiniBatchGlobalGroupAggFunction(GeneratedAggsHandleFunction genLocalAggsHandler, GeneratedAggsHandleFunction genGlobalAggsHandler, GeneratedRecordEqualiser genRecordEqualiser, org.apache.flink.table.types.logical.LogicalType[] accTypes, int indexOfCountStar, boolean generateUpdateBefore, long stateRetentionTime)	Creates a MiniBatchGlobalGroupAggFunction.
MiniBatchGroupAggFunction(GeneratedAggsHandleFunction genAggsHandler, GeneratedRecordEqualiser genRecordEqualiser, org.apache.flink.table.types.logical.LogicalType[] accTypes, org.apache.flink.table.types.logical.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	Description
ProcTimeDeduplicateKeepLastRowFunction(InternalTypeInfo<org.apache.flink.table.data.RowData> typeInfo, long stateRetentionTime, boolean generateUpdateBefore, boolean generateInsert, boolean inputInsertOnly, GeneratedRecordEqualiser genRecordEqualiser)
ProcTimeMiniBatchDeduplicateKeepLastRowFunction(InternalTypeInfo<org.apache.flink.table.data.RowData> typeInfo, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.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	Description
RetractableTopNFunction(org.apache.flink.api.common.state.StateTtlConfig ttlConfig, InternalTypeInfo<org.apache.flink.table.data.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	Description
SinkUpsertMaterializer(org.apache.flink.api.common.state.StateTtlConfig ttlConfig, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.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	Description
WindowOperatorBuilder.AggregateWindowOperatorBuilder	WindowOperatorBuilder.aggregate(GeneratedNamespaceAggsHandleFunction<?> generatedAggregateFunction, GeneratedRecordEqualiser generatedEqualiser, 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 GeneratedRecordEqualiser

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