examples/dataflow-streaming-benchmark/src/main/java/com/google/cloud/pso/pipeline/StreamingBenchmark.java
/**
   * The main entry-point for pipeline execution. This method will start the pipeline but will not
   * wait for it's execution to finish. If blocking execution is required, use the {@link
   * StreamingBenchmark#run(Options)} method to start the pipeline and invoke {@code
   * result.waitUntilFinish()} on the {@link PipelineResult}.
   *
   * @param args The command-line args passed by the executor.
   */
The main entry-point for pipeline execution. This method will start the pipeline but will not
wait for it's execution to finish. If blocking execution is required, use the {@link
StreamingBenchmark#run(Options)} method to start the pipeline and invoke {@code
result.waitUntilFinish()} on the  PipelineResult.

@param args The command-line args passed by the executor.
The main entry - point for pipeline execution . This method will start the pipeline but will not wait for it ' s execution to finish . If blocking execution is required use the { @link StreamingBenchmark#run ( Options ) } method to start the pipeline and invoke { @code result . waitUntilFinish () } on the PipelineResult . @param args The command - line args passed by the executor .
public static void main(String[] args) {
    Options options = PipelineOptionsFactory
        .fromArgs(args)
        .withValidation()
        .as(Options.class);
    run(options);
  }
public static void main ( String [ ] args ) { Options options = PipelineOptionsFactory . fromArgs ( args ) . withValidation ( ) . as ( Options . class ) ; run ( options ) ; }
The main entry-point for pipeline execution.
The main entry - point for pipeline execution .