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

Class MiniBatchIncrementalGroupAggFunction

java.lang.Object

org.apache.flink.table.runtime.operators.bundle.MapBundleFunction<RowData,RowData,RowData,RowData>

org.apache.flink.table.runtime.operators.aggregate.MiniBatchIncrementalGroupAggFunction

All Implemented Interfaces:

Serializable, Function

public class MiniBatchIncrementalGroupAggFunction
extends MapBundleFunction<RowData,RowData,RowData,RowData>

Aggregate Function used for the incremental groupby (without window) aggregate in miniBatch mode.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.flink.table.runtime.operators.bundle.MapBundleFunction

ctx

Constructor Summary

Constructors

Constructor	Description
MiniBatchIncrementalGroupAggFunction(GeneratedAggsHandleFunction genPartialAggsHandler, GeneratedAggsHandleFunction genFinalAggsHandler, KeySelector<RowData,RowData> finalKeySelector, long stateRetentionTime)

Method Summary

Modifier and Type	Method	Description
RowData	addInput(RowData previousAcc, RowData input)	Adds the given input to the given value, returning the new bundle value.
void	close()
void	finishBundle(Map<RowData,RowData> buffer, Collector<RowData> out)	Called when a bundle is finished.
void	open(ExecutionContext ctx)

Methods inherited from class java.lang.Object

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

Constructor Detail

MiniBatchIncrementalGroupAggFunction

public MiniBatchIncrementalGroupAggFunction(GeneratedAggsHandleFunction genPartialAggsHandler,
                                            GeneratedAggsHandleFunction genFinalAggsHandler,
                                            KeySelector<RowData,RowData> finalKeySelector,
                                            long stateRetentionTime)

Method Detail

open

public void open(ExecutionContext ctx)
          throws Exception

Overrides:

open in class MapBundleFunction<RowData,RowData,RowData,RowData>

Throws:

Exception

addInput

public RowData addInput(@Nullable
                        RowData previousAcc,
                        RowData input)
                 throws Exception

Description copied from class: MapBundleFunction

Adds the given input to the given value, returning the new bundle value.

Specified by:

addInput in class MapBundleFunction<RowData,RowData,RowData,RowData>

Parameters:

previousAcc - the existing bundle value, maybe null

input - the given input, not null

Throws:

Exception

finishBundle

public void finishBundle(Map<RowData,RowData> buffer,
                         Collector<RowData> out)
                  throws Exception

Description copied from class: MapBundleFunction

Called when a bundle is finished. Transform a bundle to zero, one, or more output elements.

Specified by:

finishBundle in class MapBundleFunction<RowData,RowData,RowData,RowData>

Throws:

Exception

close

public void close()
           throws Exception

Overrides:

close in class MapBundleFunction<RowData,RowData,RowData,RowData>

Throws:

Exception