org.apache.flink.table.runtime.operators.aggregate.window.combines

Class LocalAggCombiner

java.lang.Object

org.apache.flink.table.runtime.operators.aggregate.window.combines.LocalAggCombiner

All Implemented Interfaces:

RecordsCombiner

public class LocalAggCombiner
extends Object
implements RecordsCombiner

An implementation of RecordsCombiner that accumulates input records into local accumulators.

Note: this only supports event-time window.

Nested Class Summary

Nested Classes

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

Nested classes/interfaces inherited from interface org.apache.flink.table.runtime.operators.window.combines.RecordsCombiner

RecordsCombiner.LocalFactory

Constructor Summary

Constructors

Constructor and Description
LocalAggCombiner(NamespaceAggsHandleFunction<Long> aggregator, Collector<RowData> collector)

Method Summary

Modifier and Type	Method and Description
void	close() Release resources allocated by this combine function.
void	combine(WindowKey windowKey, Iterator<RowData> records) Combines the buffered data into state based on the given window-key pair.

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalAggCombiner

public LocalAggCombiner(NamespaceAggsHandleFunction<Long> aggregator,
                        Collector<RowData> collector)

Method Detail

combine

public void combine(WindowKey windowKey,
                    Iterator<RowData> records)
             throws Exception

Description copied from interface: RecordsCombiner

Combines the buffered data into state based on the given window-key pair.

Specified by:

combine in interface RecordsCombiner

Parameters:

windowKey - the window-key pair that the buffered data belong to, the window-key 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: RecordsCombiner

Release resources allocated by this combine function.

Specified by:

close in interface RecordsCombiner

Throws:

Exception