org.apache.pig.tools.pigstats.spark

Class SparkCounterGroup<T>

java.lang.Object

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

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

SparkCounterGroup.LongSparkCounterGroup, SparkCounterGroup.MapSparkCounterGroup

public abstract class SparkCounterGroup<T>
extends Object
implements Serializable

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SparkCounterGroup.LongSparkCounterGroup
static class	SparkCounterGroup.MapSparkCounterGroup

Field Summary

Fields

Modifier and Type	Field and Description
protected String	groupDisplayName
protected String	groupName
protected JavaSparkContext	javaSparkContext
protected Map<String,SparkCounter<T>>	sparkCounters

Constructor Summary

Constructors

Constructor and Description
SparkCounterGroup(String groupName, String groupDisplayName, JavaSparkContext javaSparkContext)

Method Summary

Modifier and Type	Method and Description
abstract void	createCounter(String name, T initValue)
SparkCounter	getCounter(String name)
String	getGroupDisplayName()
String	getGroupName()
Map<String,SparkCounter<T>>	getSparkCounters()
void	setGroupDisplayName(String groupDisplayName)

Methods inherited from class java.lang.Object

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

Field Detail

groupName

protected String groupName

groupDisplayName

protected String groupDisplayName

sparkCounters

protected Map<String,SparkCounter<T>> sparkCounters

javaSparkContext

protected transient JavaSparkContext javaSparkContext

Constructor Detail

SparkCounterGroup

public SparkCounterGroup(String groupName,
                         String groupDisplayName,
                         JavaSparkContext javaSparkContext)

Method Detail

createCounter

public abstract void createCounter(String name,
                                   T initValue)

getCounter

public SparkCounter getCounter(String name)

getGroupName

public String getGroupName()

getGroupDisplayName

public String getGroupDisplayName()

setGroupDisplayName

public void setGroupDisplayName(String groupDisplayName)

getSparkCounters

public Map<String,SparkCounter<T>> getSparkCounters()