Class ObjectSummaryAggregator
- java.lang.Object
-
- org.apache.flink.api.java.summarize.aggregation.ObjectSummaryAggregator
-
- All Implemented Interfaces:
Serializable,Aggregator<Object,ObjectColumnSummary>
@Internal public class ObjectSummaryAggregator extends Object implements Aggregator<Object,ObjectColumnSummary>
Aggregatorthat calculates statistics forObjectvalues.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description ObjectSummaryAggregator()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaggregate(Object value)Add a value to the current aggregation.voidcombine(Aggregator<Object,ObjectColumnSummary> otherSameType)Combine two aggregations of the same type.ObjectColumnSummaryresult()Provide the final result of the aggregation.
-
-
-
Method Detail
-
aggregate
public void aggregate(Object value)
Description copied from interface:AggregatorAdd a value to the current aggregation.- Specified by:
aggregatein interfaceAggregator<Object,ObjectColumnSummary>
-
combine
public void combine(Aggregator<Object,ObjectColumnSummary> otherSameType)
Description copied from interface:AggregatorCombine two aggregations of the same type.(Implementations will need to do an unchecked cast).
- Specified by:
combinein interfaceAggregator<Object,ObjectColumnSummary>
-
result
public ObjectColumnSummary result()
Description copied from interface:AggregatorProvide the final result of the aggregation.- Specified by:
resultin interfaceAggregator<Object,ObjectColumnSummary>
-
-