org.apache.pig.tools.pigstats.spark

Class SparkCounterGroup<T>

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable

Direct Known Subclasses:

SparkCounterGroup.LongSparkCounterGroup, SparkCounterGroup.MapSparkCounterGroup

public abstract class SparkCounterGroup<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	SparkCounterGroup.LongSparkCounterGroup
static class	SparkCounterGroup.MapSparkCounterGroup

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

groupName

protected java.lang.String groupName

groupDisplayName

protected java.lang.String groupDisplayName

sparkCounters

protected java.util.Map<java.lang.String,SparkCounter<T>> sparkCounters

javaSparkContext

protected transient JavaSparkContext javaSparkContext

Constructor Detail

SparkCounterGroup

public SparkCounterGroup(java.lang.String groupName,
                         java.lang.String groupDisplayName,
                         JavaSparkContext javaSparkContext)

Method Detail

createCounter

public abstract void createCounter(java.lang.String name,
                                   T initValue)

getCounter

public SparkCounter getCounter(java.lang.String name)

getGroupName

public java.lang.String getGroupName()

getGroupDisplayName

public java.lang.String getGroupDisplayName()

setGroupDisplayName

public void setGroupDisplayName(java.lang.String groupDisplayName)

getSparkCounters

public java.util.Map<java.lang.String,SparkCounter<T>> getSparkCounters()