Package org.apache.flink.api.common.aggregators

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 an Aggregator 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

Modifier and Type	Method	Description
Aggregator<T>	getAggregator()	Gets the aggregator.
String	getName()	Gets the name that the aggregator is registered under.

Methods inherited from class java.lang.Object

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

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.