org.apache.flink.runtime.accumulators

Class StringifiedAccumulatorResult

java.lang.Object

org.apache.flink.runtime.accumulators.StringifiedAccumulatorResult

All Implemented Interfaces:

Serializable

public class StringifiedAccumulatorResult
extends Object
implements Serializable

Container class that transports the result of an accumulator as set of strings.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
StringifiedAccumulatorResult(String name, String type, String value)

Method Summary

Modifier and Type	Method and Description
String	getName()
String	getType()
String	getValue()
static StringifiedAccumulatorResult[]	stringifyAccumulatorResults(Map<String,OptionalFailure<Accumulator<?,?>>> accs) Flatten a map of accumulator names to Accumulator instances into an array of StringifiedAccumulatorResult values.

Methods inherited from class java.lang.Object

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

Constructor Detail

StringifiedAccumulatorResult

public StringifiedAccumulatorResult(String name,
                                    String type,
                                    String value)

Method Detail

getName

public String getName()

getType

public String getType()

getValue

public String getValue()

stringifyAccumulatorResults

public static StringifiedAccumulatorResult[] stringifyAccumulatorResults(Map<String,OptionalFailure<Accumulator<?,?>>> accs)

Flatten a map of accumulator names to Accumulator instances into an array of StringifiedAccumulatorResult values.