TupleSummaryAggregator (Flink : Java 1.20.1-cp2 API)

java.lang.Object
- org.apache.flink.api.java.summarize.aggregation.TupleSummaryAggregator<R>

All Implemented Interfaces:

Serializable, Aggregator<org.apache.flink.api.java.tuple.Tuple,R>
```
@Internal
public class TupleSummaryAggregator<R extends org.apache.flink.api.java.tuple.Tuple>
extends Object
implements Aggregator<org.apache.flink.api.java.tuple.Tuple,R>
```
Aggregate tuples using an array of aggregators, one for each "column" or position within the Tuple.

See Also:

Serialized Form

Constructor Summary

Constructors
Constructor Description

TupleSummaryAggregator(Aggregator[] columnAggregators)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`aggregate(org.apache.flink.api.java.tuple.Tuple value)`	Add a value to the current aggregation.
`void`	`combine(Aggregator<org.apache.flink.api.java.tuple.Tuple,R> other)`	Combine two aggregations of the same type.
`R`	`result()`	Provide the final result of the aggregation.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - TupleSummaryAggregator
```
public TupleSummaryAggregator(Aggregator[] columnAggregators)
```
- Method Detail
  - aggregate
```
public void aggregate(org.apache.flink.api.java.tuple.Tuple value)
```
    Description copied from interface: Aggregator
    
    Add a value to the current aggregation.
    
    Specified by:
    
    aggregate in interface Aggregator<org.apache.flink.api.java.tuple.Tuple,R extends org.apache.flink.api.java.tuple.Tuple>
  - combine
```
public void combine(Aggregator<org.apache.flink.api.java.tuple.Tuple,R> other)
```
    Description copied from interface: Aggregator
    
    Combine two aggregations of the same type.
    (Implementations will need to do an unchecked cast).
    
    Specified by:
    
    combine in interface Aggregator<org.apache.flink.api.java.tuple.Tuple,R extends org.apache.flink.api.java.tuple.Tuple>
  - result
```
public R result()
```
    Description copied from interface: Aggregator
    
    Provide the final result of the aggregation.
    
    Specified by:
    
    result in interface Aggregator<org.apache.flink.api.java.tuple.Tuple,R extends org.apache.flink.api.java.tuple.Tuple>