Package org.apache.nemo.client.beam

Class NemoRunner

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

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      static NemoRunner create()
      Creates and returns a new NemoRunner with default options.
      static NemoRunner create​(NemoPipelineOptions options)
      Creates and returns a new NemoRunner with specified options.
      static NemoRunner fromOptions​(org.apache.beam.sdk.options.PipelineOptions options)
      Static initializer for creating PipelineRunner with the given options.
      NemoPipelineResult run​(org.apache.beam.sdk.Pipeline pipeline)
      Method to run the Pipeline.

      • Methods inherited from class org.apache.beam.sdk.PipelineRunner

        run, run

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • 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.