This project has retired. For details please refer to its Attic page.

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

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

SparkCounter(String group, String name, long value)

Method Summary

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