examples/iot-nirvana/pipeline/src/main/java/com/google/cloud/demo/iot/nirvana/pipeline/TemperaturePipeline.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
   * TemperaturePipeline#run(TemperaturePipelineOptions)} 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
TemperaturePipeline#run(TemperaturePipelineOptions)} method to start the pipeline and invoke
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 TemperaturePipeline#run ( TemperaturePipelineOptions ) } method to start the pipeline and invoke result . waitUntilFinish () on the PipelineResult . @param args The command - line args passed by the executor .
public static void main(String[] args) {
    try {
      TemperaturePipelineOptions options =
          PipelineOptionsFactory.fromArgs(args)
              .withValidation()
              .as(TemperaturePipelineOptions.class);
      run(options);
    } catch (FormatException e) {
      LOG.error("Pipeline critical failure", e);
      throw new RuntimeException(e);
    }
  }
public static void main ( String [ ] args ) { try { TemperaturePipelineOptions options = PipelineOptionsFactory . fromArgs ( args ) . withValidation ( ) . as ( TemperaturePipelineOptions . class ) ; run ( options ) ; } catch ( FormatException e ) { LOG . error ( "Pipeline critical failure" , e ) ; throw new RuntimeException ( e ) ; } }
The main entry-point for pipeline execution.
The main entry - point for pipeline execution .