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: 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.