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

Packages that use RecordEqualiser

Package	Description
org.apache.flink.table.runtime.generated
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.process
org.apache.flink.table.runtime.operators.window.groupwindow.operator

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

Methods in org.apache.flink.table.runtime.generated with parameters of type RecordEqualiser

Modifier and Type	Method	Description
void	ProcessTableRunner.initialize(org.apache.flink.api.common.state.State[] stateHandles, HashFunction[] stateHashCode, RecordEqualiser[] stateEquals, boolean emitRowtime, AbstractProcessTableOperator.RunnerContext runnerContext, AbstractProcessTableOperator.RunnerOnTimerContext runnerOnTimerContext, PassThroughCollectorBase evalCollector, PassAllCollector onTimerCollector)

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.processLastRowOnChangelogWithFilter(FilterCondition.Context context, 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, FilterCondition filterCondition)
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.process

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

Constructor	Description
AbstractProcessTableOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.table.data.RowData> parameters, List<RuntimeTableSemantics> tableSemantics, List<RuntimeStateInfo> stateInfos, ProcessTableRunner processTableRunner, HashFunction[] stateHashCode, RecordEqualiser[] stateEquals, RuntimeChangelogMode producedChangelogMode)
ProcessRowTableOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.table.data.RowData> parameters, List<RuntimeTableSemantics> tableSemantics, List<RuntimeStateInfo> stateInfos, ProcessTableRunner processTableRunner, HashFunction[] stateHashCode, RecordEqualiser[] stateEquals, RuntimeChangelogMode producedChangelogMode)
ProcessSetTableOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<org.apache.flink.table.data.RowData> parameters, List<RuntimeTableSemantics> tableSemantics, List<RuntimeStateInfo> stateInfos, ProcessTableRunner processTableRunner, HashFunction[] stateHashCode, RecordEqualiser[] stateEquals, RuntimeChangelogMode producedChangelogMode)

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)