org.apache.hadoop.mapred

Class SparkCounter

java.lang.Object

org.apache.hadoop.mapreduce.Counter

org.apache.hadoop.mapred.Counters.Counter

org.apache.hadoop.mapred.SparkCounter

All Implemented Interfaces:

org.apache.hadoop.io.Writable

public class SparkCounter
extends org.apache.hadoop.mapred.Counters.Counter

Constructor Summary

Constructors

Constructor and Description
SparkCounter(String group, String name, org.apache.spark.Accumulator<Map<String,Map<String,Long>>> accum)
SparkCounter(String group, String name, long value)

Method Summary

Methods

Modifier and Type	Method and Description
long	getCounter()
String	getDisplayName()
String	getName()
long	getValue()
void	increment(long inc)
void	setValue(long newValue)

Methods inherited from class org.apache.hadoop.mapred.Counters.Counter

makeEscapedCompactString, setDisplayName

Methods inherited from class org.apache.hadoop.mapreduce.Counter

equals, hashCode, readFields, write

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SparkCounter

public SparkCounter(String group,
            String name,
            org.apache.spark.Accumulator<Map<String,Map<String,Long>>> accum)

SparkCounter

public SparkCounter(String group,
            String name,
            long value)

Method Detail

getName

public String getName()

Overrides:

getName in class org.apache.hadoop.mapreduce.Counter

getDisplayName

public String getDisplayName()

Overrides:

getDisplayName in class org.apache.hadoop.mapreduce.Counter

getValue

public long getValue()

Overrides:

getValue in class org.apache.hadoop.mapreduce.Counter

getCounter

public long getCounter()

Overrides:

getCounter in class org.apache.hadoop.mapred.Counters.Counter

increment

public void increment(long inc)

Overrides:

increment in class org.apache.hadoop.mapreduce.Counter

setValue

public void setValue(long newValue)

Overrides:

setValue in class org.apache.hadoop.mapreduce.Counter