org.apache.beam.runners.apex

Class TestApexRunner

java.lang.Object

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

org.apache.beam.runners.apex.TestApexRunner

public class TestApexRunner
extends PipelineRunner<ApexRunnerResult>

Apex PipelineRunner for testing.

Method Summary

Modifier and Type	Method and Description
static TestApexRunner	fromOptions(PipelineOptions options)
ApexRunnerResult	run(Pipeline pipeline) Processes the given Pipeline, potentially asynchronously, returning a runner-specific type of result.
static com.datatorrent.api.DAG	translate(Pipeline pipeline, ApexPipelineOptions options)

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 TestApexRunner fromOptions(PipelineOptions options)

translate

public static com.datatorrent.api.DAG translate(Pipeline pipeline,
                                                ApexPipelineOptions options)

run

public ApexRunnerResult 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<ApexRunnerResult>