Class AggregatorWithName<T extends Value>
- java.lang.Object
-
- org.apache.flink.api.common.aggregators.AggregatorWithName<T>
-
@PublicEvolving public class AggregatorWithName<T extends Value> extends Object
Simple utility class holding anAggregator
with the name it is registered under.
-
-
Constructor Summary
Constructors Constructor Description AggregatorWithName(String name, Aggregator<T> aggregator)
Creates a new instance for the given aggregator and name.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Aggregator<T>
getAggregator()
Gets the aggregator.String
getName()
Gets the name that the aggregator is registered under.
-
-
-
Constructor Detail
-
AggregatorWithName
public AggregatorWithName(String name, Aggregator<T> aggregator)
Creates a new instance for the given aggregator and name.- Parameters:
name
- The name that the aggregator is registered under.aggregator
- The aggregator.
-
-
Method Detail
-
getName
public String getName()
Gets the name that the aggregator is registered under.- Returns:
- The name that the aggregator is registered under.
-
getAggregator
public Aggregator<T> getAggregator()
Gets the aggregator.- Returns:
- The aggregator.
-
-