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