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.
MetricsContainerStepMapAccumulator	AccumulatorV2 implementation for MetricsContainerStepMap.
SparkBeamMetric	An adapter between the MetricsContainerStepMap and Codahale's Metric interface.
SparkBeamMetricSource	A Spark Source that is tailored to expose a SparkBeamMetric, wrapping an underlying MetricResults instance.
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.