org.apache.hadoop.mapred

Class SparkCounter

java.lang.Object

org.apache.hadoop.mapred.Counters.Counter

org.apache.hadoop.mapred.SparkCounter

All Implemented Interfaces:

org.apache.hadoop.io.Writable, org.apache.hadoop.mapreduce.Counter

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

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

contentEquals, equals, getUnderlyingCounter, hashCode, makeEscapedCompactString, readFields, setDisplayName, 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()

Specified by:

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

Overrides:

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

getDisplayName

public String getDisplayName()

Specified by:

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

Overrides:

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

getValue

public long getValue()

Specified by:

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

Overrides:

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

getCounter

public long getCounter()

Overrides:

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

increment

public void increment(long inc)

Specified by:

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

Overrides:

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

setValue

public void setValue(long newValue)

Specified by:

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

Overrides:

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