Package org.apache.beam.runners.jet

Class JetRunner

java.lang.Object

org.apache.beam.sdk.PipelineRunner<PipelineResult>

org.apache.beam.runners.jet.JetRunner

public class JetRunner
extends PipelineRunner<PipelineResult>

Jet specific implementation of Beam's PipelineRunner.

Method Summary

Modifier and Type	Method	Description
static JetRunner	fromOptions(PipelineOptions options)
static JetRunner	fromOptions(PipelineOptions options, Function<com.hazelcast.client.config.ClientConfig,com.hazelcast.jet.JetInstance> jetClientSupplier)
PipelineResult	run(Pipeline pipeline)	Processes the given Pipeline, potentially asynchronously, returning a runner-specific type of result.

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 Details

fromOptions

public static JetRunner fromOptions(PipelineOptions options)

fromOptions

public static JetRunner fromOptions(PipelineOptions options,
 Function<com.hazelcast.client.config.ClientConfig,com.hazelcast.jet.JetInstance> jetClientSupplier)

run

public PipelineResult run(Pipeline pipeline)

Description copied from class: PipelineRunner

Processes the given Pipeline, potentially asynchronously, returning a runner-specific type of result.

Specified by:

run in class PipelineRunner<PipelineResult>