This project has retired. For details please refer to its
Attic page.
CounterAccumulatorParam (Apache Crunch 0.9.0 API)
org.apache.crunch.impl.spark
Class CounterAccumulatorParam
java.lang.Object
org.apache.crunch.impl.spark.CounterAccumulatorParam
- All Implemented Interfaces:
- Serializable, org.apache.spark.AccumulableParam<Map<String,Long>,Map<String,Long>>, org.apache.spark.AccumulatorParam<Map<String,Long>>, scala.ScalaObject
public class CounterAccumulatorParam
- extends Object
- implements org.apache.spark.AccumulatorParam<Map<String,Long>>
- See Also:
- Serialized Form
Method Summary |
Map<String,Long> |
addAccumulator(Map<String,Long> current,
Map<String,Long> added)
|
Map<String,Long> |
addInPlace(Map<String,Long> first,
Map<String,Long> second)
|
Map<String,Long> |
zero(Map<String,Long> counts)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
CounterAccumulatorParam
public CounterAccumulatorParam()
addAccumulator
public Map<String,Long> addAccumulator(Map<String,Long> current,
Map<String,Long> added)
- Specified by:
addAccumulator
in interface org.apache.spark.AccumulableParam<Map<String,Long>,Map<String,Long>>
- Specified by:
addAccumulator
in interface org.apache.spark.AccumulatorParam<Map<String,Long>>
addInPlace
public Map<String,Long> addInPlace(Map<String,Long> first,
Map<String,Long> second)
- Specified by:
addInPlace
in interface org.apache.spark.AccumulableParam<Map<String,Long>,Map<String,Long>>
zero
public Map<String,Long> zero(Map<String,Long> counts)
- Specified by:
zero
in interface org.apache.spark.AccumulableParam<Map<String,Long>,Map<String,Long>>
Copyright © 2014 The Apache Software Foundation. All Rights Reserved.