public static class SparkCounter.MapSparkCounter extends SparkCounter<Map<String,Long>>
SparkCounter.LongSparkCounter, SparkCounter.MapSparkCounter
Constructor and Description |
---|
MapSparkCounter() |
MapSparkCounter(String name,
String displayName,
String groupName,
Map<String,Long> initValue,
JavaSparkContext sparkContext) |
Modifier and Type | Method and Description |
---|---|
protected <any> |
createAccumulatorParam() |
getDisplayName, getName, getValue, increment, setDisplayName
protected <any> createAccumulatorParam()
createAccumulatorParam
in class SparkCounter<Map<String,Long>>
Copyright © 2007-2017 The Apache Software Foundation