Project Crunch has retired. For details please refer to its Attic page.
SparkCounter (Apache Crunch 0.11.0 API)

org.apache.hadoop.mapred
Class SparkCounter

java.lang.Object
  extended by org.apache.hadoop.mapreduce.Counter
      extended by org.apache.hadoop.mapred.Counters.Counter
          extended by 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


Copyright © 2014 The Apache Software Foundation. All Rights Reserved.