org.apache.beam.sdk.metrics

Class MetricResults

java.lang.Object

org.apache.beam.sdk.metrics.MetricResults

@Experimental(value=METRICS)
public abstract class MetricResults
extends java.lang.Object

Methods for interacting with the metrics of a pipeline that has been executed. Accessed via PipelineResult.metrics().

Constructor Summary

Constructors

Constructor and Description
MetricResults()

Method Summary

Modifier and Type	Method and Description
abstract MetricQueryResults	queryMetrics(MetricsFilter filter) Query for all metric values that match a given filter.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MetricResults

public MetricResults()

Method Detail

queryMetrics

public abstract MetricQueryResults queryMetrics(@Nullable
                                                MetricsFilter filter)

Query for all metric values that match a given filter.

The filter may filter based on the namespace and/or name of the metric, as well as the step that reported the metric.

For each type of metric, the result contains an iterable of all metrics of that type that matched the filter. Each MetricResult includes the name of the metric, the step in which it was reported and the MetricResult.getCommitted() and MetricResult.getAttempted() values.

Note that runners differ in their support for committed and attempted values.

Example: Querying the metrics reported from the SomeDoFn example in Metrics could be done as follows:

 Pipeline p = ...;
 p.apply("create1", Create.of("hello")).apply("myStepName1", ParDo.of(new SomeDoFn()));
 p.apply("create2", Create.of("world")).apply("myStepName2", ParDo.of(new SomeDoFn()));
 PipelineResult result = p.run();
 MetricResults metrics = result.metrics();
 MetricQueryResults metricResults = metrics.queryMetrics(new MetricsFilter.Builder()
     .addNameFilter("my-counter")
     .addStepFilter("myStepName1").addStepFilter("myStepName2")
     .build());
 Iterable<MetricResult<Long>> counters = metricResults.counters();
 // counters should contain the value of my-counter reported from each of the ParDo
 // applications.