DataflowPipelineOptions:在arg解析后使用.setRunner显式设置runner

import org.apache.beam.sdk.options.Default;
import org.apache.beam.sdk.options.Description;
import org.apache.beam.sdk.options.PipelineOptions;
import org.apache.beam.sdk.options.Validation.Required;

public interface MyOptions extends PipelineOptions {
  @Description("Dataflow runner")
  @Default.String("DataflowRunner")
  String getRunner();
  void setRunner(String value);

  @Description("Google Cloud project ID")
  @Required
  String getProject();
  void setProject(String value);

  @Description("Dataflow staging location")
  @Required
  String getStagingLocation();
  void setStagingLocation(String value);

  @Description("Dataflow temp location")
  @Required
  String getTempLocation();
  void setTempLocation(String value);

  @Description("Dataflow job name")
  @Required
  String getJobName();
  void setJobName(String value);

  @Description("Google Cloud zone")
  @Default.String("us-central1-f")
  String getZone();
  void setZone(String value);

  @Description("Dataflow worker machine type")
  @Default.String("n1-standard-1")
  String getWorkerMachineType();
  void setWorkerMachineType(String value);

  @Description("Number of Dataflow worker nodes")
  @Default.Integer(1)
  Integer getNumWorkers();
  void setNumWorkers(Integer value);
}