org.apache.flink.api.java.summarize.aggregation

Class TupleSummaryAggregator<R extends Tuple>

java.lang.Object

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

All Implemented Interfaces:

Serializable, Aggregator<Tuple,R>

@Internal
public class TupleSummaryAggregator<R extends Tuple>
extends Object
implements Aggregator<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 and Description
TupleSummaryAggregator(Aggregator[] columnAggregators)

Method Summary

Modifier and Type	Method and Description
void	aggregate(Tuple value) Add a value to the current aggregation.
void	combine(Aggregator<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(Tuple value)

Description copied from interface: Aggregator

Add a value to the current aggregation.

Specified by:

aggregate in interface Aggregator<Tuple,R extends Tuple>

combine

public void combine(Aggregator<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<Tuple,R extends Tuple>

result

public R result()

Description copied from interface: Aggregator

Provide the final result of the aggregation.

Specified by:

result in interface Aggregator<Tuple,R extends Tuple>