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

Class BooleanSummaryAggregator

java.lang.Object

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

All Implemented Interfaces:

Serializable, Aggregator<Boolean,BooleanColumnSummary>

@Internal
public class BooleanSummaryAggregator
extends Object
implements Aggregator<Boolean,BooleanColumnSummary>

Aggregator for Boolean type.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
BooleanSummaryAggregator()

Method Summary

Modifier and Type	Method and Description
void	aggregate(Boolean value) Add a value to the current aggregation.
void	combine(Aggregator<Boolean,BooleanColumnSummary> otherSameType) Combine two aggregations of the same type.
BooleanColumnSummary	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

BooleanSummaryAggregator

public BooleanSummaryAggregator()

Method Detail

aggregate

public void aggregate(Boolean value)

Description copied from interface: Aggregator

Add a value to the current aggregation.

Specified by:

aggregate in interface Aggregator<Boolean,BooleanColumnSummary>

combine

public void combine(Aggregator<Boolean,BooleanColumnSummary> otherSameType)

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<Boolean,BooleanColumnSummary>

result

public BooleanColumnSummary result()

Description copied from interface: Aggregator

Provide the final result of the aggregation.

Specified by:

result in interface Aggregator<Boolean,BooleanColumnSummary>