Uses of Interface
org.apache.flink.table.runtime.operators.window.combines.RecordsCombiner

Packages that use RecordsCombiner

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

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

Constructors in org.apache.flink.table.runtime.operators.aggregate.window.buffers with parameters of type RecordsCombiner

Constructor	Description
RecordsWindowBuffer(Object operatorOwner, org.apache.flink.runtime.memory.MemoryManager memoryManager, long memorySize, RecordsCombiner combineFunction, PagedTypeSerializer<org.apache.flink.table.data.RowData> keySer, AbstractRowDataSerializer<org.apache.flink.table.data.RowData> inputSer, boolean requiresCopy, java.time.ZoneId shiftTimeZone)

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

Classes in org.apache.flink.table.runtime.operators.aggregate.window.combines that implement RecordsCombiner

Modifier and Type	Class	Description
class	AggCombiner	An implementation of RecordsCombiner that accumulates input records into the window accumulator state.
class	GlobalAggCombiner	An implementation of RecordsCombiner that accumulates local accumulators records into the window accumulator state.
class	LocalAggCombiner	An implementation of RecordsCombiner that accumulates input records into local accumulators.

Methods in org.apache.flink.table.runtime.operators.aggregate.window.combines that return RecordsCombiner

Modifier and Type	Method	Description
RecordsCombiner	AggCombiner.Factory.createRecordsCombiner(org.apache.flink.api.common.functions.RuntimeContext runtimeContext, WindowTimerService<Long> timerService, org.apache.flink.runtime.state.KeyedStateBackend<org.apache.flink.table.data.RowData> stateBackend, WindowState<Long> windowState, boolean isEventTime)
RecordsCombiner	GlobalAggCombiner.Factory.createRecordsCombiner(org.apache.flink.api.common.functions.RuntimeContext runtimeContext, WindowTimerService<Long> timerService, org.apache.flink.runtime.state.KeyedStateBackend<org.apache.flink.table.data.RowData> stateBackend, WindowState<Long> windowState, boolean isEventTime)
RecordsCombiner	LocalAggCombiner.Factory.createRecordsCombiner(org.apache.flink.api.common.functions.RuntimeContext runtimeContext, org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> collector)

Uses of RecordsCombiner in org.apache.flink.table.runtime.operators.deduplicate.window.combines

Classes in org.apache.flink.table.runtime.operators.deduplicate.window.combines that implement RecordsCombiner

Modifier and Type	Class	Description
class	RowTimeDeduplicateRecordsCombiner	An implementation of RecordsCombiner that stores the first/last records of incremental input records into the window state.

Methods in org.apache.flink.table.runtime.operators.deduplicate.window.combines that return RecordsCombiner

Modifier and Type	Method	Description
RecordsCombiner	RowTimeDeduplicateRecordsCombiner.Factory.createRecordsCombiner(org.apache.flink.api.common.functions.RuntimeContext runtimeContext, WindowTimerService<Long> timerService, org.apache.flink.runtime.state.KeyedStateBackend<org.apache.flink.table.data.RowData> stateBackend, WindowState<Long> windowState, boolean isEventTime)

Uses of RecordsCombiner in org.apache.flink.table.runtime.operators.rank.window.combines

Classes in org.apache.flink.table.runtime.operators.rank.window.combines that implement RecordsCombiner

Modifier and Type	Class	Description
class	TopNRecordsCombiner	An implementation of RecordsCombiner that save topN records of incremental input records into the window state.

Methods in org.apache.flink.table.runtime.operators.rank.window.combines that return RecordsCombiner

Modifier and Type	Method	Description
RecordsCombiner	TopNRecordsCombiner.Factory.createRecordsCombiner(org.apache.flink.api.common.functions.RuntimeContext runtimeContext, WindowTimerService<Long> timerService, org.apache.flink.runtime.state.KeyedStateBackend<org.apache.flink.table.data.RowData> stateBackend, WindowState<Long> windowState, boolean isEventTime)

Uses of RecordsCombiner in org.apache.flink.table.runtime.operators.window.combines

Methods in org.apache.flink.table.runtime.operators.window.combines that return RecordsCombiner

Modifier and Type	Method	Description
RecordsCombiner	RecordsCombiner.Factory.createRecordsCombiner(org.apache.flink.api.common.functions.RuntimeContext runtimeContext, WindowTimerService<Long> timerService, org.apache.flink.runtime.state.KeyedStateBackend<org.apache.flink.table.data.RowData> stateBackend, WindowState<Long> windowState, boolean isEventTime)	Creates a RecordsCombiner that can combine buffered data into states.
RecordsCombiner	RecordsCombiner.LocalFactory.createRecordsCombiner(org.apache.flink.api.common.functions.RuntimeContext runtimeContext, org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> collector)