A word-counting workflow.
Bases: DoFn
DoFn
Generates user metrics and outputs same element.
Returns the processed element and increments the metrics.
Given an initialized Pipeline applies transforms and runs it.