org.apache.beam.sdk.testing

Interface TestPipelineOptions

All Superinterfaces:

HasDisplayData, PipelineOptions

All Known Subinterfaces:

BigtableChangeStreamTestOptions, TestBigQueryOptions, TestDataflowPipelineOptions, TestPortablePipelineOptions, TestPubsubOptions, TestSparkPipelineOptions, TestUniversalRunner.Options

public interface TestPipelineOptions
extends PipelineOptions

TestPipelineOptions is a set of options for test pipelines.

See Also:

TestPipeline

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	TestPipelineOptions.AlwaysPassMatcher Matcher which will always pass.
static class	TestPipelineOptions.AlwaysPassMatcherFactory Factory for PipelineResult matchers which always pass.

Nested classes/interfaces inherited from interface org.apache.beam.sdk.options.PipelineOptions

PipelineOptions.AtomicLongFactory, PipelineOptions.CheckEnabled, PipelineOptions.DirectRunner, PipelineOptions.JobNameFactory, PipelineOptions.UserAgentFactory

Method Summary

Modifier and Type	Method and Description
SerializableMatcher<PipelineResult>	getOnCreateMatcher()
SerializableMatcher<PipelineResult>	getOnSuccessMatcher()
java.lang.String	getTempRoot()
@Nullable java.lang.Long	getTestTimeoutSeconds()
boolean	isBlockOnRun()
void	setBlockOnRun(boolean value)
void	setOnCreateMatcher(SerializableMatcher<PipelineResult> value)
void	setOnSuccessMatcher(SerializableMatcher<PipelineResult> value)
void	setTempRoot(java.lang.String value)
void	setTestTimeoutSeconds(java.lang.Long value)

Methods inherited from interface org.apache.beam.sdk.options.PipelineOptions

as, getJobName, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, revision, setJobName, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent

Methods inherited from interface org.apache.beam.sdk.transforms.display.HasDisplayData

populateDisplayData

Method Detail

getTempRoot

java.lang.String getTempRoot()

setTempRoot

void setTempRoot(java.lang.String value)

getOnCreateMatcher

@Default.InstanceFactory(value=TestPipelineOptions.AlwaysPassMatcherFactory.class)
SerializableMatcher<PipelineResult> getOnCreateMatcher()

setOnCreateMatcher

void setOnCreateMatcher(SerializableMatcher<PipelineResult> value)

getOnSuccessMatcher

@Default.InstanceFactory(value=TestPipelineOptions.AlwaysPassMatcherFactory.class)
SerializableMatcher<PipelineResult> getOnSuccessMatcher()

setOnSuccessMatcher

void setOnSuccessMatcher(SerializableMatcher<PipelineResult> value)

getTestTimeoutSeconds

@Default.Long(value=900L)
@Nullable java.lang.Long getTestTimeoutSeconds()

setTestTimeoutSeconds

void setTestTimeoutSeconds(java.lang.Long value)

isBlockOnRun

@Default.Boolean(value=true)
boolean isBlockOnRun()

setBlockOnRun

void setBlockOnRun(boolean value)