apache_beam.runners.dataflow.dataflow_exercise_streaming_metrics_pipeline module

A word-counting workflow.

class apache_beam.runners.dataflow.dataflow_exercise_streaming_metrics_pipeline.StreamingUserMetricsDoFn[source]

Bases: DoFn

Generates user metrics and outputs same element.

start_bundle()[source]
process(element)[source]

Returns the processed element and increments the metrics.

finish_bundle()[source]
apache_beam.runners.dataflow.dataflow_exercise_streaming_metrics_pipeline.run(argv=None)[source]

Given an initialized Pipeline applies transforms and runs it.