Uses of Interface
org.apache.flink.table.runtime.generated.RecordEqualiser

Packages that use RecordEqualiser

Package	Description
org.apache.flink.table.runtime.operators.aggregate
org.apache.flink.table.runtime.operators.aggregate.asyncwindow.buffers
org.apache.flink.table.runtime.operators.aggregate.utils
org.apache.flink.table.runtime.operators.deduplicate.utils
org.apache.flink.table.runtime.operators.window.groupwindow.operator

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

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

Modifier and Type	Field	Description
protected RecordEqualiser	GroupAggFunctionBase.equaliser

Uses of RecordEqualiser 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 RecordEqualiser

Constructor	Description
AsyncStateRecordsWindowBuffer(Object operatorOwner, org.apache.flink.runtime.memory.MemoryManager memoryManager, long memorySize, AsyncStateRecordsCombiner combineFunction, PagedTypeSerializer<org.apache.flink.table.data.RowData> keySer, AbstractRowDataSerializer<org.apache.flink.table.data.RowData> inputSer, RecordEqualiser keyEqualiser, AsyncStateKeyContext keyContext, ZoneId shiftTimeZone)

Uses of RecordEqualiser in org.apache.flink.table.runtime.operators.aggregate.utils

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

Constructor	Description
GroupAggHelper(RecordCounter recordCounter, boolean generateUpdateBefore, org.apache.flink.api.common.state.StateTtlConfig ttlConfig, AggsHandleFunction function, RecordEqualiser equaliser)

Uses of RecordEqualiser in org.apache.flink.table.runtime.operators.deduplicate.utils

Methods in org.apache.flink.table.runtime.operators.deduplicate.utils with parameters of type RecordEqualiser

Modifier and Type	Method	Description
static void	DeduplicateFunctionHelper.processLastRowOnChangelog(org.apache.flink.table.data.RowData currentRow, boolean generateUpdateBefore, org.apache.flink.api.common.state.ValueState<org.apache.flink.table.data.RowData> state, org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out, boolean isStateTtlEnabled, RecordEqualiser equaliser)	Processes element to deduplicate on keys, sends current element as last row, retracts previous element if needed.
static void	DeduplicateFunctionHelper.processLastRowOnProcTime(org.apache.flink.table.data.RowData currentRow, boolean generateUpdateBefore, boolean generateInsert, org.apache.flink.api.common.state.ValueState<org.apache.flink.table.data.RowData> state, org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out, boolean isStateTtlEnabled, RecordEqualiser equaliser)	Processes element to deduplicate on keys with process time semantic, sends current element as last row, retracts previous element if needed.

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 RecordEqualiser	AggregateWindowOperator.equaliser	The 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.AggregateWindowOperatorBuilder	WindowOperatorBuilder.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)