public class AggregatorsAccumulator
extends java.lang.Object
Accumulators
are required to be wrapped in a Singleton.Constructor and Description |
---|
AggregatorsAccumulator() |
Modifier and Type | Method and Description |
---|---|
static void |
clear() |
static NamedAggregatorsAccumulator |
getInstance() |
static void |
init(org.apache.spark.api.java.JavaSparkContext jsc)
Init aggregators accumulator if it has not been initiated.
|
public static void init(org.apache.spark.api.java.JavaSparkContext jsc)
public static NamedAggregatorsAccumulator getInstance()
public static void clear()