org.apache.beam.runners.flink

Class TestFlinkRunner

java.lang.Object

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

org.apache.beam.runners.flink.TestFlinkRunner

public class TestFlinkRunner
extends PipelineRunner<PipelineResult>

Test Flink runner.

Method Summary

Modifier and Type	Method and Description
static TestFlinkRunner	create(boolean streaming)
static TestFlinkRunner	fromOptions(PipelineOptions options)
PipelineOptions	getPipelineOptions()
PipelineResult	run(Pipeline pipeline) Processes the given Pipeline, potentially asynchronously, returning a runner-specific type of result.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

fromOptions

public static TestFlinkRunner fromOptions(PipelineOptions options)

create

public static TestFlinkRunner create(boolean streaming)

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>

getPipelineOptions

public PipelineOptions getPipelineOptions()