Package org.apache.beam.runners.jet

Class JetRunner

  • public class JetRunner
extends org.apache.beam.sdk.PipelineRunner<org.apache.beam.sdk.PipelineResult>
    Jet specific implementation of Beam's PipelineRunner.

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      static JetRunner fromOptions​(org.apache.beam.sdk.options.PipelineOptions options)  
      static JetRunner fromOptions​(org.apache.beam.sdk.options.PipelineOptions options, java.util.function.Function<com.hazelcast.client.config.ClientConfig,​com.hazelcast.jet.JetInstance> jetClientSupplier)  
      org.apache.beam.sdk.PipelineResult run​(org.apache.beam.sdk.Pipeline pipeline)  

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

        create, run, run

      • Methods inherited from class java.lang.Object

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

    • Method Detail

      • fromOptions

        public static JetRunner fromOptions​(org.apache.beam.sdk.options.PipelineOptions options)

      • fromOptions

        public static JetRunner fromOptions​(org.apache.beam.sdk.options.PipelineOptions options,
                                    java.util.function.Function<com.hazelcast.client.config.ClientConfig,​com.hazelcast.jet.JetInstance> jetClientSupplier)

      • run

        public org.apache.beam.sdk.PipelineResult run​(org.apache.beam.sdk.Pipeline pipeline)
        Specified by:
        run in class org.apache.beam.sdk.PipelineRunner<org.apache.beam.sdk.PipelineResult>