org.apache.pig.tools.pigstats.spark

Class SparkCounter<T>

java.lang.Object

org.apache.pig.tools.pigstats.spark.SparkCounter<T>

All Implemented Interfaces:

java.io.Serializable

Direct Known Subclasses:

SparkCounter.LongSparkCounter, SparkCounter.MapSparkCounter

public abstract class SparkCounter<T>
extends java.lang.Object
implements java.io.Serializable

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SparkCounter.LongSparkCounter
static class	SparkCounter.MapSparkCounter

Constructor Summary

Constructors

Constructor and Description
SparkCounter()
SparkCounter(java.lang.String name, java.lang.String displayName, java.lang.String groupName, T initValue, JavaSparkContext sparkContext)

Method Summary

Modifier and Type	Method and Description
protected abstract <any>	createAccumulatorParam()
java.lang.String	getDisplayName()
java.lang.String	getName()
T	getValue()
void	increment(T incr)
void	setDisplayName(java.lang.String displayName)

Methods inherited from class java.lang.Object

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

Constructor Detail

SparkCounter

public SparkCounter()

SparkCounter

public SparkCounter(java.lang.String name,
                    java.lang.String displayName,
                    java.lang.String groupName,
                    T initValue,
                    JavaSparkContext sparkContext)

Method Detail

createAccumulatorParam

protected abstract <any> createAccumulatorParam()

getValue

public T getValue()

increment

public void increment(T incr)

getName

public java.lang.String getName()

getDisplayName

public java.lang.String getDisplayName()

setDisplayName

public void setDisplayName(java.lang.String displayName)