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

Class ValueSummaryAggregator.DoubleValueSummaryAggregator

java.lang.Object

org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator<org.apache.flink.types.DoubleValue,Double,NumericColumnSummary<Double>,DoubleSummaryAggregator>

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

All Implemented Interfaces:

Serializable, Aggregator<org.apache.flink.types.DoubleValue,NumericColumnSummary<Double>>

Enclosing class:

ValueSummaryAggregator<VT extends org.apache.flink.types.Value,PT,R,A extends Aggregator<PT,R>>

public static class ValueSummaryAggregator.DoubleValueSummaryAggregator
extends ValueSummaryAggregator<org.apache.flink.types.DoubleValue,Double,NumericColumnSummary<Double>,DoubleSummaryAggregator>

A ValueSummaryAggregator for Double.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.api.java.summarize.aggregation.ValueSummaryAggregator

ValueSummaryAggregator.BooleanValueSummaryAggregator, ValueSummaryAggregator.DoubleValueSummaryAggregator, ValueSummaryAggregator.FloatValueSummaryAggregator, ValueSummaryAggregator.IntegerValueSummaryAggregator, ValueSummaryAggregator.LongValueSummaryAggregator, ValueSummaryAggregator.ShortValueSummaryAggregator, ValueSummaryAggregator.StringValueSummaryAggregator

Constructor Summary

Constructors

Constructor	Description
DoubleValueSummaryAggregator()

Method Summary

Modifier and Type	Method	Description
protected Double	getValue(org.apache.flink.types.DoubleValue value)	Get the value out of a value type.
protected DoubleSummaryAggregator	initPrimitiveAggregator()	Initialize an aggregator that can be used for the underlying primitive in the Value type.

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

aggregate, combine, result

Methods inherited from class java.lang.Object

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

Constructor Detail

DoubleValueSummaryAggregator

public DoubleValueSummaryAggregator()

Method Detail

initPrimitiveAggregator

protected DoubleSummaryAggregator initPrimitiveAggregator()

Description copied from class: ValueSummaryAggregator

Initialize an aggregator that can be used for the underlying primitive in the Value type.

E.g. DoubleValues can easily be converted to Double and could use an underlying Aggregator<Double,?>

Specified by:

initPrimitiveAggregator in class ValueSummaryAggregator<org.apache.flink.types.DoubleValue,Double,NumericColumnSummary<Double>,DoubleSummaryAggregator>

getValue

protected Double getValue(org.apache.flink.types.DoubleValue value)

Description copied from class: ValueSummaryAggregator

Get the value out of a value type.

Specified by:

getValue in class ValueSummaryAggregator<org.apache.flink.types.DoubleValue,Double,NumericColumnSummary<Double>,DoubleSummaryAggregator>