SparkCounters (Pig 0.17.0 API)

public class SparkCounters
extends Object
implements Serializable, PigWarnCounter

Constructors
Constructor and Description
`SparkCounters(JavaSparkContext javaSparkContext)`

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`createCounter(Enum<?> key)`
`void`	`createCounter(String groupName, Enum<?> key)`
`void`	`createCounter(String groupName, String counterName)`
`void`	`createCounter(String groupName, String counterName, Object initValue)`
`SparkCounter`	`getCounter(Enum<?> key)`
`SparkCounter`	`getCounter(String groupName, String counterName)`
`Map<String,SparkCounterGroup>`	`getSparkCounterGroups()`
`Object`	`getValue(String groupName, String counterName)`
`void`	`increment(Enum<?> key, long incrValue)`
`void`	`increment(String groupName, String counterName, long value)`
`boolean`	`incrWarnCounter(Enum<?> name, Object incr)`
`boolean`	`incrWarnCounter(String group, String name, Object incr)`

public SparkCounters(JavaSparkContext javaSparkContext)

public void createCounter(Enum<?> key)

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

public void createCounter(String groupName,
                          String counterName)

public void createCounter(String groupName,
                          String counterName,
                          Object initValue)

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

public void increment(String groupName,
                      String counterName,
                      long value)

public Object getValue(String groupName,
                       String counterName)

public SparkCounter getCounter(String groupName,
                               String counterName)

public SparkCounter getCounter(Enum<?> key)

public Map<String,SparkCounterGroup> getSparkCounterGroups()

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

public boolean incrWarnCounter(String group,
                               String name,
                               Object incr)

Class SparkCounters