DataflowRunner

DataflowRunner is a PipelineRunner that produces a DataflowPipelineJob.

DataflowRunner requires that appName option is defined.

Creating Instance

DataflowRunner takes a single DataflowPipelineOptions to be created.

DataflowRunner is created using fromOptions utility.

fromOptions Utility

DataflowRunner fromOptions(
  PipelineOptions options)

fromOptions…​FIXME

DataflowClient

DataflowPipelineTranslator

PCollections of Indexed Format

PTransform with Non-Deterministic Key Coders