org.apache.beam.runners.spark.structuredstreaming.aggregators

Class NamedAggregators

java.lang.Object

org.apache.beam.runners.spark.structuredstreaming.aggregators.NamedAggregators

All Implemented Interfaces:

java.io.Serializable

public class NamedAggregators
extends java.lang.Object
implements java.io.Serializable

This class wraps a map of named aggregators. Spark expects that all accumulators be declared before a job is launched. Beam allows aggregators to be used and incremented on the fly. We create a map of named aggregators and instantiate in the the spark context before the job is launched. We can then add aggregators on the fly in Spark.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	NamedAggregators.State<InputT,InterT,OutputT>

Constructor Summary

Constructors

Constructor and Description
NamedAggregators() Constructs a new NamedAggregators instance.

Method Summary

Modifier and Type	Method and Description
<T> T	getValue(java.lang.String name, java.lang.Class<T> typeClass)
NamedAggregators	merge(NamedAggregators other) Merges another NamedAggregators instance with this instance.
java.util.Map<java.lang.String,?>	renderAll()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

NamedAggregators

public NamedAggregators()

Constructs a new NamedAggregators instance.

Method Detail

getValue

public <T> T getValue(java.lang.String name,
                      java.lang.Class<T> typeClass)

Type Parameters:

T - Type to be returned.

Parameters:

name - Name of aggregator to retrieve.

typeClass - Type class to cast the value to.

Returns:

the value of the aggregator associated with the specified name, or null if the specified aggregator could not be found.

renderAll

public java.util.Map<java.lang.String,?> renderAll()

Returns:

a map of all the aggregator names and their rendered values

merge

public NamedAggregators merge(NamedAggregators other)

Merges another NamedAggregators instance with this instance.

Parameters:

other - The other instance of named aggregators ot merge.

Returns:

This instance of Named aggregators with associated states updated to reflect the other instance's aggregators.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object