Uses of Interface
org.apache.flink.api.java.summarize.aggregation.Aggregator

Packages that use Aggregator

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

Uses of Aggregator in org.apache.flink.api.java.summarize.aggregation

Classes in org.apache.flink.api.java.summarize.aggregation with type parameters of type Aggregator

Modifier and Type	Class and Description
class	ValueSummaryAggregator<VT extends Value,PT,R,A extends Aggregator<PT,R>> This is a generic Aggregator for Value types like StringValue, DoubleValue, etc.

Methods in org.apache.flink.api.java.summarize.aggregation that return Aggregator

Modifier and Type	Method and Description
static <T,R> Aggregator<T,R>	SummaryAggregatorFactory.create(Class<T> type) Create a SummaryAggregator for the supplied type.
protected Aggregator<Integer,Integer>	IntegerSummaryAggregator.initMax()
protected Aggregator<Float,Float>	FloatSummaryAggregator.initMax()
protected Aggregator<Short,Short>	ShortSummaryAggregator.initMax()
protected Aggregator<Double,Double>	DoubleSummaryAggregator.initMax()
protected abstract Aggregator<T,T>	NumericSummaryAggregator.initMax()
protected Aggregator<Long,Long>	LongSummaryAggregator.initMax()
protected Aggregator<Integer,Integer>	IntegerSummaryAggregator.initMin()
protected Aggregator<Float,Float>	FloatSummaryAggregator.initMin()
protected Aggregator<Short,Short>	ShortSummaryAggregator.initMin()
protected Aggregator<Double,Double>	DoubleSummaryAggregator.initMin()
protected abstract Aggregator<T,T>	NumericSummaryAggregator.initMin()
protected Aggregator<Long,Long>	LongSummaryAggregator.initMin()
protected Aggregator<Integer,Integer>	IntegerSummaryAggregator.initSum()
protected Aggregator<Float,Float>	FloatSummaryAggregator.initSum()
protected Aggregator<Short,Short>	ShortSummaryAggregator.initSum()
protected Aggregator<Double,Double>	DoubleSummaryAggregator.initSum()
protected abstract Aggregator<T,T>	NumericSummaryAggregator.initSum()
protected Aggregator<Long,Long>	LongSummaryAggregator.initSum()

Methods in org.apache.flink.api.java.summarize.aggregation with parameters of type Aggregator

Modifier and Type	Method and Description
void	BooleanSummaryAggregator.combine(Aggregator<Boolean,BooleanColumnSummary> otherSameType)
void	DoubleSummaryAggregator.MinDoubleAggregator.combine(Aggregator<Double,Double> other)
void	DoubleSummaryAggregator.MaxDoubleAggregator.combine(Aggregator<Double,Double> other)
void	DoubleSummaryAggregator.SumDoubleAggregator.combine(Aggregator<Double,Double> other)
void	FloatSummaryAggregator.MinFloatAggregator.combine(Aggregator<Float,Float> other)
void	FloatSummaryAggregator.MaxFloatAggregator.combine(Aggregator<Float,Float> other)
void	FloatSummaryAggregator.SumFloatAggregator.combine(Aggregator<Float,Float> other)
void	IntegerSummaryAggregator.MinIntegerAggregator.combine(Aggregator<Integer,Integer> other)
void	IntegerSummaryAggregator.MaxIntegerAggregator.combine(Aggregator<Integer,Integer> other)
void	IntegerSummaryAggregator.SumIntegerAggregator.combine(Aggregator<Integer,Integer> other)
void	LongSummaryAggregator.MinLongAggregator.combine(Aggregator<Long,Long> other)
void	LongSummaryAggregator.MaxLongAggregator.combine(Aggregator<Long,Long> other)
void	ObjectSummaryAggregator.combine(Aggregator<Object,ObjectColumnSummary> otherSameType)
void	ShortSummaryAggregator.MinShortAggregator.combine(Aggregator<Short,Short> other)
void	ShortSummaryAggregator.MaxShortAggregator.combine(Aggregator<Short,Short> other)
void	ShortSummaryAggregator.SumShortAggregator.combine(Aggregator<Short,Short> other)
void	StringSummaryAggregator.combine(Aggregator<String,StringColumnSummary> otherSameType)
void	NumericSummaryAggregator.combine(Aggregator<T,NumericColumnSummary<T>> otherSameType) combine two aggregations.
void	Aggregator.combine(Aggregator<T,R> otherSameType) Combine two aggregations of the same type.
void	TupleSummaryAggregator.combine(Aggregator<Tuple,R> other)
void	ValueSummaryAggregator.combine(Aggregator<VT,R> otherSameType)

Constructors in org.apache.flink.api.java.summarize.aggregation with parameters of type Aggregator

Constructor and Description
TupleSummaryAggregator(Aggregator[] columnAggregators)