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

Class SummaryAggregatorFactory

java.lang.Object

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

@Internal
public class SummaryAggregatorFactory
extends Object

Factory for creating Summary Aggregators.

Constructor Summary

Constructors

Constructor and Description
SummaryAggregatorFactory()

Method Summary

Modifier and Type	Method and Description
static <T,R> Aggregator<T,R>	create(Class<T> type) Create a SummaryAggregator for the supplied type.
static <R extends Tuple> TupleSummaryAggregator<R>	create(TupleTypeInfoBase<?> inType)

Methods inherited from class java.lang.Object

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

Constructor Detail

SummaryAggregatorFactory

public SummaryAggregatorFactory()

Method Detail

create

public static <R extends Tuple> TupleSummaryAggregator<R> create(TupleTypeInfoBase<?> inType)

create

public static <T,R> Aggregator<T,R> create(Class<T> type)

Create a SummaryAggregator for the supplied type.

Type Parameters:

T - the type to aggregate

R - the result type of the aggregation