Package org.apache.beam.runners.spark.metrics

Provides internal utilities for implementing Beam metrics using Spark accumulators.

See: Description

Class Summary

Class	Description
AggregatorMetric	An adapter between the NamedAggregators and Codahale's Metric interface.
AggregatorMetricSource	A Spark Source that is tailored to expose an AggregatorMetric, wrapping an underlying NamedAggregators instance.
CompositeSource	Composite source made up of several MetricRegistry instances.
MetricsAccumulator	For resilience, Accumulators are required to be wrapped in a Singleton.
MetricsAccumulator.AccumulatorCheckpointingSparkListener	Spark Listener which checkpoints MetricsContainerStepMap values for fault-tolerance.
SparkBeamMetricSource	A Spark Source that is tailored to expose a SparkBeamMetric, wrapping an underlying MetricResults instance.
SparkMetricsContainerStepMap	Sole purpose of this class is to override SparkMetricsContainerStepMap.toString() of MetricsContainerStepMap in order to show meaningful metrics in Spark Web Interface.
WithMetricsSupport	A MetricRegistry decorator-like that supports AggregatorMetric and SparkBeamMetric as Gauges.

Package org.apache.beam.runners.spark.metrics Description

Provides internal utilities for implementing Beam metrics using Spark accumulators.