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

Class LongSummaryAggregator

java.lang.Object

org.apache.flink.api.java.summarize.aggregation.NumericSummaryAggregator<Long>

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

All Implemented Interfaces:

Serializable, Aggregator<Long,NumericColumnSummary<Long>>

@Internal
public class LongSummaryAggregator
extends NumericSummaryAggregator<Long>

Aggregator that can handle Long types.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	LongSummaryAggregator.MaxLongAggregator	Aggregator for max operation.
static class	LongSummaryAggregator.MinLongAggregator	Aggregator for min operation.

Constructor Summary

Constructors

Constructor	Description
LongSummaryAggregator()

Method Summary

Modifier and Type	Method	Description
protected Aggregator<Long,Long>	initMax()
protected Aggregator<Long,Long>	initMin()
protected Aggregator<Long,Long>	initSum()
protected boolean	isInfinite(Long number)
protected boolean	isNan(Long number)

Methods inherited from class org.apache.flink.api.java.summarize.aggregation.NumericSummaryAggregator

aggregate, combine, result

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LongSummaryAggregator

public LongSummaryAggregator()

Method Detail

initMin

protected Aggregator<Long,Long> initMin()

Specified by:

initMin in class NumericSummaryAggregator<Long>

initMax

protected Aggregator<Long,Long> initMax()

Specified by:

initMax in class NumericSummaryAggregator<Long>

initSum

protected Aggregator<Long,Long> initSum()

Specified by:

initSum in class NumericSummaryAggregator<Long>

isNan

protected boolean isNan(Long number)

Specified by:

isNan in class NumericSummaryAggregator<Long>

isInfinite

protected boolean isInfinite(Long number)

Specified by:

isInfinite in class NumericSummaryAggregator<Long>