Package org.apache.flink.table.runtime.operators.aggregate.asyncwindow.combines

Class AsyncStateAggCombiner

java.lang.Object

org.apache.flink.table.runtime.operators.aggregate.asyncwindow.combines.AsyncStateAggCombiner

All Implemented Interfaces:

AsyncStateRecordsCombiner

public class AsyncStateAggCombiner
extends Object
implements AsyncStateRecordsCombiner

An implementation of RecordsCombiner that accumulates input records into the window accumulator with async state.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AsyncStateAggCombiner.Factory	Factory to create AsyncStateAggCombiner.

Constructor Summary

Constructors

Constructor	Description
AsyncStateAggCombiner(WindowTimerService<Long> timerService, WindowAsyncValueState<Long> accState, NamespaceAggsHandleFunction<Long> aggregator, boolean isEventTime)

Method Summary

Modifier and Type	Method	Description
org.apache.flink.api.common.state.v2.StateFuture<Void>	asyncCombine(Long window, Iterator<org.apache.flink.table.data.RowData> records)	Combines the buffered data into async state based on the given window.
void	close()	Release resources allocated by this combine function.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AsyncStateAggCombiner

public AsyncStateAggCombiner(WindowTimerService<Long> timerService,
                             WindowAsyncValueState<Long> accState,
                             NamespaceAggsHandleFunction<Long> aggregator,
                             boolean isEventTime)

Method Detail

asyncCombine

public org.apache.flink.api.common.state.v2.StateFuture<Void> asyncCombine(Long window,
                                                                           Iterator<org.apache.flink.table.data.RowData> records)
                                                                    throws Exception

Description copied from interface: AsyncStateRecordsCombiner

Combines the buffered data into async state based on the given window.

Specified by:

asyncCombine in interface AsyncStateRecordsCombiner

Parameters:

window - the window that the buffered data belong to, the window object is reused.

records - the buffered data, the iterator and RowData objects are reused.

Throws:

Exception

close

public void close()
           throws Exception

Description copied from interface: AsyncStateRecordsCombiner

Release resources allocated by this combine function.

Specified by:

close in interface AsyncStateRecordsCombiner

Throws:

Exception