PipelineOptions

PipelineOptions is used to configure a Pipeline.

PipelineOptions can be created using PipelineOptionsFactory utilities:

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

HasDisplayData

PipelineOptions is a HasDisplayData.

JSON SerDe

PipelineOptions uses the following annotations to define the classes for JSON serialization and deserialization:

@JsonSerialize(using = Serializer.class)
@JsonDeserialize(using = Deserializer.class)