Package org.apache.beam.runners.twister2

Class Twister2Runner

java.lang.Object

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

org.apache.beam.runners.twister2.Twister2Runner

@Deprecated
public class Twister2Runner
extends PipelineRunner<PipelineResult>

Deprecated.

The support for twister2 is scheduled for removal in Beam 3.0.

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	Description
protected	Twister2Runner(Twister2PipelineOptions options)	Deprecated.

Method Summary

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

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

Twister2Runner

protected Twister2Runner(Twister2PipelineOptions options)

Deprecated.

Method Details

fromOptions

public static Twister2Runner fromOptions(PipelineOptions options)

Deprecated.

run

public PipelineResult run(Pipeline pipeline)

Deprecated.

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)

Deprecated.