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.SparkContext sparkContext)
Init aggregators accumulator if it has not been initiated.
|
public static void init(org.apache.spark.SparkContext sparkContext)
public static NamedAggregatorsAccumulator getInstance()
public static void clear()