org.apache.pig.tools.pigstats.spark

Class SparkCounters

java.lang.Object

org.apache.pig.tools.pigstats.spark.SparkCounters

All Implemented Interfaces:

java.io.Serializable, PigWarnCounter

public class SparkCounters
extends java.lang.Object
implements java.io.Serializable, PigWarnCounter

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SparkCounters(JavaSparkContext javaSparkContext)

Method Summary

Modifier and Type	Method and Description
void	createCounter(java.lang.Enum<?> key)
void	createCounter(java.lang.String groupName, java.lang.Enum<?> key)
void	createCounter(java.lang.String groupName, java.lang.String counterName)
void	createCounter(java.lang.String groupName, java.lang.String counterName, java.lang.Object initValue)
SparkCounter	getCounter(java.lang.Enum<?> key)
SparkCounter	getCounter(java.lang.String groupName, java.lang.String counterName)
java.util.Map<java.lang.String,SparkCounterGroup>	getSparkCounterGroups()
java.lang.Object	getValue(java.lang.String groupName, java.lang.String counterName)
void	increment(java.lang.Enum<?> key, long incrValue)
void	increment(java.lang.String groupName, java.lang.String counterName, long value)
boolean	incrWarnCounter(java.lang.Enum<?> name, java.lang.Object incr)
boolean	incrWarnCounter(java.lang.String group, java.lang.String name, java.lang.Object incr)

Methods inherited from class java.lang.Object

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

Constructor Detail

SparkCounters

public SparkCounters(JavaSparkContext javaSparkContext)

Method Detail

createCounter

public void createCounter(java.lang.Enum<?> key)

createCounter

public void createCounter(java.lang.String groupName,
                          java.lang.Enum<?> key)

createCounter

public void createCounter(java.lang.String groupName,
                          java.lang.String counterName)

createCounter

public void createCounter(java.lang.String groupName,
                          java.lang.String counterName,
                          java.lang.Object initValue)

increment

public void increment(java.lang.Enum<?> key,
                      long incrValue)

increment

public void increment(java.lang.String groupName,
                      java.lang.String counterName,
                      long value)

getValue

public java.lang.Object getValue(java.lang.String groupName,
                                 java.lang.String counterName)

getCounter

public SparkCounter getCounter(java.lang.String groupName,
                               java.lang.String counterName)

getCounter

public SparkCounter getCounter(java.lang.Enum<?> key)

getSparkCounterGroups

public java.util.Map<java.lang.String,SparkCounterGroup> getSparkCounterGroups()

incrWarnCounter

public boolean incrWarnCounter(java.lang.Enum<?> name,
                               java.lang.Object incr)

Specified by:

incrWarnCounter in interface PigWarnCounter

incrWarnCounter

public boolean incrWarnCounter(java.lang.String group,
                               java.lang.String name,
                               java.lang.Object incr)

Specified by:

incrWarnCounter in interface PigWarnCounter