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.aggregate.async
org.apache.flink.table.runtime.operators.aggregate.asyncwindow.buffers
org.apache.flink.table.runtime.operators.aggregate.window
org.apache.flink.table.runtime.operators.deduplicate
org.apache.flink.table.runtime.operators.over
org.apache.flink.table.runtime.operators.process
org.apache.flink.table.runtime.operators.rank
org.apache.flink.table.runtime.operators.sink
org.apache.flink.table.runtime.operators.window.groupwindow.operator
org.apache.flink.table.runtime.sequencedmultisetstate
org.apache.flink.table.runtime.sequencedmultisetstate.linked

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

Fields in org.apache.flink.table.runtime.operators.aggregate declared as GeneratedRecordEqualiser

Modifier and Type	Field	Description
protected GeneratedRecordEqualiser	GroupAggFunctionBase.genRecordEqualiser	The code generated equaliser used to equal RowData.

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.
GroupAggFunctionBase(GeneratedAggsHandleFunction genAggsHandler, GeneratedRecordEqualiser genRecordEqualiser, org.apache.flink.table.types.logical.LogicalType[] accTypes, int indexOfCountStar, boolean generateUpdateBefore, long stateRetentionTime)
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.aggregate.async

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

Constructor	Description
AsyncStateGroupAggFunction(GeneratedAggsHandleFunction genAggsHandler, GeneratedRecordEqualiser genRecordEqualiser, org.apache.flink.table.types.logical.LogicalType[] accTypes, int indexOfCountStar, boolean generateUpdateBefore, long stateRetentionTime)	Creates a AsyncStateGroupAggFunction.

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

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

Constructor	Description
Factory(PagedTypeSerializer<org.apache.flink.table.data.RowData> keySer, AbstractRowDataSerializer<org.apache.flink.table.data.RowData> inputSer, AsyncStateRecordsCombiner.Factory combinerFactory, GeneratedRecordEqualiser generatedKeyEqualiser)

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

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

Modifier and Type	Method	Description
WindowAggOperatorBuilder	WindowAggOperatorBuilder.generatedKeyEqualiser(GeneratedRecordEqualiser generatedKeyEqualiser)

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, GeneratedFilterCondition filterCondition)
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, GeneratedFilterCondition genFilterCondition)

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

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

Constructor	Description
AbstractNonTimeUnboundedPrecedingOver(long stateRetentionTime, GeneratedAggsHandleFunction genAggsHandler, GeneratedRecordEqualiser genRecordEqualiser, GeneratedRecordEqualiser genSortKeyEqualiser, GeneratedRecordComparator genSortKeyComparator, org.apache.flink.table.types.logical.LogicalType[] accTypes, org.apache.flink.table.types.logical.LogicalType[] inputFieldTypes, org.apache.flink.table.types.logical.LogicalType[] sortKeyTypes, RowDataKeySelector sortKeySelector, InternalTypeInfo<org.apache.flink.table.data.RowData> accKeyRowTypeInfo)
NonTimeRangeUnboundedPrecedingFunction(long stateRetentionTime, GeneratedAggsHandleFunction genAggsHandler, GeneratedRecordEqualiser genRecordEqualiser, GeneratedRecordEqualiser genSortKeyEqualiser, GeneratedRecordComparator genSortKeyComparator, org.apache.flink.table.types.logical.LogicalType[] accTypes, org.apache.flink.table.types.logical.LogicalType[] inputFieldTypes, org.apache.flink.table.types.logical.LogicalType[] sortKeyTypes, RowDataKeySelector sortKeySelector)
NonTimeRowsUnboundedPrecedingFunction(long stateRetentionTime, GeneratedAggsHandleFunction genAggsHandler, GeneratedRecordEqualiser genRecordEqualiser, GeneratedRecordEqualiser genSortKeyEqualiser, GeneratedRecordComparator genSortKeyComparator, org.apache.flink.table.types.logical.LogicalType[] accTypes, org.apache.flink.table.types.logical.LogicalType[] inputFieldTypes, org.apache.flink.table.types.logical.LogicalType[] sortKeyTypes, RowDataKeySelector sortKeySelector)

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

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

Constructor	Description
ProcessTableOperatorFactory(List<RuntimeTableSemantics> tableSemantics, List<RuntimeStateInfo> stateInfos, GeneratedProcessTableRunner generatedProcessTableRunner, GeneratedHashFunction[] generatedStateHashCode, GeneratedRecordEqualiser[] generatedStateEquals, RuntimeChangelogMode producedChangelogMode)

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

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

Modifier and Type	Method	Description
static SinkUpsertMaterializer	SinkUpsertMaterializer.create(org.apache.flink.api.common.state.StateTtlConfig ttlConfig, org.apache.flink.table.types.logical.RowType physicalRowType, GeneratedRecordEqualiser rowEqualiser, GeneratedRecordEqualiser upsertKeyEqualiser, int[] inputUpsertKey)
static SinkUpsertMaterializerV2	SinkUpsertMaterializerV2.create(org.apache.flink.table.types.logical.RowType physicalRowType, GeneratedRecordEqualiser rowEqualiser, GeneratedRecordEqualiser upsertKeyEqualiser, GeneratedHashFunction rowHashFunction, GeneratedHashFunction upsertKeyHashFunction, int[] inputUpsertKey, SequencedMultiSetStateConfig stateSettings)

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.groupwindow.operator

Methods in org.apache.flink.table.runtime.operators.window.groupwindow.operator 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.groupwindow.operator with parameters of type GeneratedRecordEqualiser

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

Uses of GeneratedRecordEqualiser in org.apache.flink.table.runtime.sequencedmultisetstate

Fields in org.apache.flink.table.runtime.sequencedmultisetstate declared as GeneratedRecordEqualiser

Modifier and Type	Field	Description
GeneratedRecordEqualiser	SequencedMultiSetStateContext.generatedKeyEqualiser

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

Constructor

Description

SequencedMultiSetStateContext(org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> keySerializer, GeneratedRecordEqualiser generatedKeyEqualiser, GeneratedHashFunction generatedKeyHashFunction, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> recordSerializer, SequencedMultiSetStateContext.KeyExtractor keyExtractor, SequencedMultiSetStateConfig config)

Uses of GeneratedRecordEqualiser in org.apache.flink.table.runtime.sequencedmultisetstate.linked

Constructors in org.apache.flink.table.runtime.sequencedmultisetstate.linked with parameters of type GeneratedRecordEqualiser

Constructor	Description
RowDataKeySerializer(org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> serializer, RecordEqualiser equalizerInstance, HashFunction hashFunctionInstance, GeneratedRecordEqualiser equaliser, GeneratedHashFunction hashFunction)