Class NemoRunner


  • public final class NemoRunner
    extends org.apache.beam.sdk.PipelineRunner<NemoPipelineResult>
    Runner class for BEAM programs.
    • Method Detail

      • create

        public static NemoRunner create()
        Creates and returns a new NemoRunner with default options.
        Returns:
        A pipeline runner with default options.
      • create

        public static NemoRunner create​(NemoPipelineOptions options)
        Creates and returns a new NemoRunner with specified options.
        Parameters:
        options - The NemoPipelineOptions to use when executing the job.
        Returns:
        A pipeline runner that will execute with specified options.
      • fromOptions

        public static NemoRunner fromOptions​(org.apache.beam.sdk.options.PipelineOptions options)
        Static initializer for creating PipelineRunner with the given options.
        Parameters:
        options - given PipelineOptions.
        Returns:
        The created PipelineRunner.
      • run

        public NemoPipelineResult run​(org.apache.beam.sdk.Pipeline pipeline)
        Method to run the Pipeline.
        Specified by:
        run in class org.apache.beam.sdk.PipelineRunner<NemoPipelineResult>
        Parameters:
        pipeline - the Pipeline to run.
        Returns:
        The result of the pipeline.