apache_beam.runners.dataflow.dataflow_exercise_metrics_pipeline module¶

A word-counting workflow.

apache_beam.runners.dataflow.dataflow_exercise_metrics_pipeline.common_metric_matchers()[source]¶: MetricResult matchers common to all tests.

apache_beam.runners.dataflow.dataflow_exercise_metrics_pipeline.fn_api_metric_matchers()[source]¶: MetricResult matchers with adjusted step names for the FN API DF test.

apache_beam.runners.dataflow.dataflow_exercise_metrics_pipeline.legacy_metric_matchers()[source]¶: MetricResult matchers with adjusted step names for the legacy DF test.

class apache_beam.runners.dataflow.dataflow_exercise_metrics_pipeline.UserMetricsDoFn[source]¶

Bases: apache_beam.transforms.core.DoFn

Parse each line of input text into words.

start_bundle()[source]¶

process(element)[source]¶: Returns the processed element and increments the metrics.

finish_bundle()[source]¶

apache_beam.runners.dataflow.dataflow_exercise_metrics_pipeline.apply_and_run(pipeline)[source]¶: Given an initialized Pipeline applies transforms and runs it.