apache_beam.runners.dataflow.dataflow_exercise_metrics_pipeline module¶
A word-counting workflow.
-
apache_beam.runners.dataflow.dataflow_exercise_metrics_pipeline.
metric_matchers
()[source]¶ MetricResult matchers common to all tests.
-
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.