org.apache.beam.runners.twister2

Class Twister2Runner

java.lang.Object

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

org.apache.beam.runners.twister2.Twister2Runner

public class Twister2Runner
extends PipelineRunner<PipelineResult>

A PipelineRunner that executes the operations in the pipeline by first translating them to a Twister2 Plan and then executing them either locally or on a Twister2 cluster, depending on the configuration.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Twister2Runner(Twister2PipelineOptions options)

Method Summary

Modifier and Type	Method and Description
static Twister2Runner	fromOptions(PipelineOptions options)
PipelineResult	run(Pipeline pipeline) Processes the given Pipeline, potentially asynchronously, returning a runner-specific type of result.
PipelineResult	runTest(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

Constructor Detail

Twister2Runner

protected Twister2Runner(Twister2PipelineOptions options)

Method Detail

fromOptions

public static Twister2Runner fromOptions(PipelineOptions options)

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>

runTest

public PipelineResult runTest(Pipeline pipeline)