LocalAggCombiner (Flink : Table : Runtime 1.19.2-cp2 API)

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 Description

static class LocalAggCombiner.Factory
Factory to create LocalAggCombiner.
- Nested classes/interfaces inherited from interface org.apache.flink.table.runtime.operators.window.tvf.combines.RecordsCombiner
  RecordsCombiner.LocalFactory

Constructor Summary

Constructors
Constructor	Description
`LocalAggCombiner(NamespaceAggsHandleFunction<Long> aggregator, org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> collector)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`close()`	Release resources allocated by this combine function.
`void`	`combine(WindowKey windowKey, Iterator<org.apache.flink.table.data.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,
                        org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> collector)
```
- Method Detail
  - combine
```
public void combine(WindowKey windowKey,
                    Iterator<org.apache.flink.table.data.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