public class MiniBatchIncrementalGroupAggFunction extends MapBundleFunction<RowData,RowData,RowData,RowData>
ctx
Constructor and Description |
---|
MiniBatchIncrementalGroupAggFunction(GeneratedAggsHandleFunction genPartialAggsHandler,
GeneratedAggsHandleFunction genFinalAggsHandler,
KeySelector<RowData,RowData> finalKeySelector,
long stateRetentionTime) |
Modifier and Type | Method and 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) |
public MiniBatchIncrementalGroupAggFunction(GeneratedAggsHandleFunction genPartialAggsHandler, GeneratedAggsHandleFunction genFinalAggsHandler, KeySelector<RowData,RowData> finalKeySelector, long stateRetentionTime)
public void open(ExecutionContext ctx) throws Exception
public RowData addInput(@Nullable RowData previousAcc, RowData input) throws Exception
MapBundleFunction
public void finishBundle(Map<RowData,RowData> buffer, Collector<RowData> out) throws Exception
MapBundleFunction
finishBundle
in class MapBundleFunction<RowData,RowData,RowData,RowData>
Exception
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.