PipelineOptions
PipelineOptions is used to configure a Pipeline.
PipelineOptions can be created using PipelineOptionsFactory utilities:
-
PipelineOptionsFactory.fromArgs (from command-line arguments)
PipelineOptions can be accessed from within a DoFn via ProcessContext.
PipelineRunner
Class<? extends PipelineRunner<?>> getRunner()
void setRunner(
Class<? extends PipelineRunner<?>> kls)
getRunner and setRunner manage the PipelineRunner for executing the pipeline
Default: direct:DirectRunner.adoc
HasDisplayData
PipelineOptions is a HasDisplayData.