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	Description
class	ValueSummaryAggregator<VT extends org.apache.flink.types.Value,PT,R,A extends Aggregator<PT,R>>	This is a generic Aggregator for Value types like StringValue, DoubleValue, etc.

Classes in org.apache.flink.api.java.summarize.aggregation that implement Aggregator

Modifier and Type	Class	Description
class	BooleanSummaryAggregator	Aggregator for Boolean type.
class	DoubleSummaryAggregator	Aggregator that can handle Double types.
static class	DoubleSummaryAggregator.MaxDoubleAggregator	Aggregator for max operation.
static class	DoubleSummaryAggregator.MinDoubleAggregator	Aggregator for min operation.
static class	DoubleSummaryAggregator.SumDoubleAggregator	Aggregator for sum operation.
class	FloatSummaryAggregator	Aggregator that can handle Float types.
static class	FloatSummaryAggregator.MaxFloatAggregator	Aggregator for max operation.
static class	FloatSummaryAggregator.MinFloatAggregator	Aggregator for min operation.
static class	FloatSummaryAggregator.SumFloatAggregator	Aggregator for sum operation.
class	IntegerSummaryAggregator	Aggregator that can handle Integer types.
static class	IntegerSummaryAggregator.MaxIntegerAggregator	Aggregator for max operation.
static class	IntegerSummaryAggregator.MinIntegerAggregator	Aggregator for min operation.
static class	IntegerSummaryAggregator.SumIntegerAggregator	Aggregator for sum operation.
class	LongSummaryAggregator	Aggregator that can handle Long types.
static class	LongSummaryAggregator.MaxLongAggregator	Aggregator for max operation.
static class	LongSummaryAggregator.MinLongAggregator	Aggregator for min operation.
class	NumericSummaryAggregator<T extends Number>	Generic aggregator for all numeric types creates a summary of a column of numbers.
class	ObjectSummaryAggregator	Aggregator that calculates statistics for Object values.
class	ShortSummaryAggregator	Aggregator that can handle Short types.
static class	ShortSummaryAggregator.MaxShortAggregator	Aggregator for max operation.
static class	ShortSummaryAggregator.MinShortAggregator	Aggregator for min operation.
static class	ShortSummaryAggregator.SumShortAggregator	Aggregator for sum operation.
class	StringSummaryAggregator	Aggregator that calculates statistics for String values.
class	TupleSummaryAggregator<R extends org.apache.flink.api.java.tuple.Tuple>	Aggregate tuples using an array of aggregators, one for each "column" or position within the Tuple.
class	ValueSummaryAggregator<VT extends org.apache.flink.types.Value,PT,R,A extends Aggregator<PT,R>>	This is a generic Aggregator for Value types like StringValue, DoubleValue, etc.
static class	ValueSummaryAggregator.BooleanValueSummaryAggregator	A ValueSummaryAggregator for Boolean.
static class	ValueSummaryAggregator.DoubleValueSummaryAggregator	A ValueSummaryAggregator for Double.
static class	ValueSummaryAggregator.FloatValueSummaryAggregator	A ValueSummaryAggregator for Float.
static class	ValueSummaryAggregator.IntegerValueSummaryAggregator	A ValueSummaryAggregator for Integer.
static class	ValueSummaryAggregator.LongValueSummaryAggregator	A ValueSummaryAggregator for Long.
static class	ValueSummaryAggregator.ShortValueSummaryAggregator	A ValueSummaryAggregator for Short.
static class	ValueSummaryAggregator.StringValueSummaryAggregator	A ValueSummaryAggregator for String.

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

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

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

Modifier and Type	Method	Description
void	Aggregator.combine(Aggregator<T,R> otherSameType)	Combine two aggregations of the same type.
void	BooleanSummaryAggregator.combine(Aggregator<Boolean,BooleanColumnSummary> otherSameType)
void	DoubleSummaryAggregator.MaxDoubleAggregator.combine(Aggregator<Double,Double> other)
void	DoubleSummaryAggregator.MinDoubleAggregator.combine(Aggregator<Double,Double> other)
void	DoubleSummaryAggregator.SumDoubleAggregator.combine(Aggregator<Double,Double> other)
void	FloatSummaryAggregator.MaxFloatAggregator.combine(Aggregator<Float,Float> other)
void	FloatSummaryAggregator.MinFloatAggregator.combine(Aggregator<Float,Float> other)
void	FloatSummaryAggregator.SumFloatAggregator.combine(Aggregator<Float,Float> other)
void	IntegerSummaryAggregator.MaxIntegerAggregator.combine(Aggregator<Integer,Integer> other)
void	IntegerSummaryAggregator.MinIntegerAggregator.combine(Aggregator<Integer,Integer> other)
void	IntegerSummaryAggregator.SumIntegerAggregator.combine(Aggregator<Integer,Integer> other)
void	LongSummaryAggregator.MaxLongAggregator.combine(Aggregator<Long,Long> other)
void	LongSummaryAggregator.MinLongAggregator.combine(Aggregator<Long,Long> other)
void	NumericSummaryAggregator.combine(Aggregator<T,NumericColumnSummary<T>> otherSameType)	combine two aggregations.
void	ObjectSummaryAggregator.combine(Aggregator<Object,ObjectColumnSummary> otherSameType)
void	ShortSummaryAggregator.MaxShortAggregator.combine(Aggregator<Short,Short> other)
void	ShortSummaryAggregator.MinShortAggregator.combine(Aggregator<Short,Short> other)
void	ShortSummaryAggregator.SumShortAggregator.combine(Aggregator<Short,Short> other)
void	StringSummaryAggregator.combine(Aggregator<String,StringColumnSummary> otherSameType)
void	TupleSummaryAggregator.combine(Aggregator<org.apache.flink.api.java.tuple.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	Description
TupleSummaryAggregator(Aggregator[] columnAggregators)