org.apache.pig.tools.pigstats.spark

Class SparkCounter.MapSparkCounter

java.lang.Object

org.apache.pig.tools.pigstats.spark.SparkCounter<java.util.Map<java.lang.String,java.lang.Long>>

org.apache.pig.tools.pigstats.spark.SparkCounter.MapSparkCounter

All Implemented Interfaces:

java.io.Serializable

Enclosing class:

SparkCounter<T>

public static class SparkCounter.MapSparkCounter
extends SparkCounter<java.util.Map<java.lang.String,java.lang.Long>>

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.pig.tools.pigstats.spark.SparkCounter

SparkCounter.LongSparkCounter, SparkCounter.MapSparkCounter

Constructor Summary

Constructors

Constructor and Description
MapSparkCounter()
MapSparkCounter(java.lang.String name, java.lang.String displayName, java.lang.String groupName, java.util.Map<java.lang.String,java.lang.Long> initValue, JavaSparkContext sparkContext)

Method Summary

Modifier and Type	Method and Description
protected <any>	createAccumulatorParam()

Methods inherited from class org.apache.pig.tools.pigstats.spark.SparkCounter

getDisplayName, getName, getValue, increment, setDisplayName

Methods inherited from class java.lang.Object

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

Constructor Detail

MapSparkCounter

public MapSparkCounter()

MapSparkCounter

public MapSparkCounter(java.lang.String name,
                       java.lang.String displayName,
                       java.lang.String groupName,
                       java.util.Map<java.lang.String,java.lang.Long> initValue,
                       JavaSparkContext sparkContext)

Method Detail

createAccumulatorParam

protected <any> createAccumulatorParam()

Specified by:

createAccumulatorParam in class SparkCounter<java.util.Map<java.lang.String,java.lang.Long>>