Package org.apache.beam.runners.twister2

Class Twister2TestRunner

java.lang.Object

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

org.apache.beam.runners.twister2.Twister2TestRunner

public class Twister2TestRunner
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. This is used for testing the Twister2 runner

Constructor Summary

Constructors

Constructor	Description
Twister2TestRunner(Twister2PipelineOptions options)

Method Summary

Modifier and Type	Method	Description
static Twister2TestRunner	fromOptions(PipelineOptions options)
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

Constructor Details

Twister2TestRunner

public Twister2TestRunner(Twister2PipelineOptions options)

Method Details

fromOptions

public static Twister2TestRunner 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>