org.apache.beam.sdk.testing

Class CrashingRunner

java.lang.Object

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

org.apache.beam.sdk.testing.CrashingRunner

public final class CrashingRunner
extends PipelineRunner<PipelineResult>

A PipelineRunner that applies no overrides and throws an exception on calls to Pipeline.run(). For use in TestPipeline to construct but not execute pipelines.

Constructor Summary

Constructors

Constructor and Description
CrashingRunner()

Method Summary

Modifier and Type	Method and Description
static CrashingRunner	fromOptions(PipelineOptions opts)
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 Detail

CrashingRunner

public CrashingRunner()

Method Detail

fromOptions

public static CrashingRunner fromOptions(PipelineOptions opts)

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>