public class MetricsAccumulator
extends java.lang.Object
Accumulators
are required to be wrapped in a Singleton.Modifier and Type | Class and Description |
---|---|
static class |
MetricsAccumulator.AccumulatorCheckpointingSparkListener
Spark Listener which checkpoints
MetricsContainerStepMap values for fault-tolerance. |
Constructor and Description |
---|
MetricsAccumulator() |
Modifier and Type | Method and Description |
---|---|
static void |
clear() |
static MetricsContainerStepMapAccumulator |
getInstance() |
static void |
init(SparkPipelineOptions opts,
org.apache.spark.api.java.JavaSparkContext jsc)
Init metrics accumulator if it has not been initiated.
|
public static void init(SparkPipelineOptions opts, org.apache.spark.api.java.JavaSparkContext jsc)
public static MetricsContainerStepMapAccumulator getInstance()
public static void clear()