Set Dataflow pipeline options from your Java code

MyMainFile.java

import org.apache.beam.runners.dataflow.options.DataflowPipelineOptions;
import org.apache.beam.sdk.options.PipelineOptionsFactory;


public static void main(String[] args) {
  PipelineOptions opts =
    PipelineOptionsFactory.fromArgs(args);

  DataflowPipelineOptions dataflowPipelineOptions =
    opts.as(DataflowPipelineOptions.class);
  
  dataflowPipelineOptions.setEnableStreamingEngine(true);
  dataflowPipelineOptions.setJobName("Overwrite job name");
  
  ...
}