Package org.apache.beam.sdk.testing

Interface TestPipelineOptions

All Superinterfaces:

HasDisplayData, PipelineOptions

All Known Subinterfaces:

BigtableChangeStreamTestOptions, ElasticsearchIOITCommon.ElasticsearchPipelineOptions, TestBigQueryOptions, TestDataflowPipelineOptions, TestPortablePipelineOptions, TestPrismPipelineOptions, 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	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	Description
SerializableMatcher<PipelineResult>	getOnCreateMatcher()
SerializableMatcher<PipelineResult>	getOnSuccessMatcher()
String	getTempRoot()
@Nullable Long	getTestTimeoutSeconds()
boolean	isBlockOnRun()
void	setBlockOnRun(boolean value)
void	setOnCreateMatcher(SerializableMatcher<PipelineResult> value)
void	setOnSuccessMatcher(SerializableMatcher<PipelineResult> value)
void	setTempRoot(String value)
void	setTestTimeoutSeconds(Long value)

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

populateDisplayData

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

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

Method Details

getTempRoot

String getTempRoot()

setTempRoot

void setTempRoot(String value)

getOnCreateMatcher

@InstanceFactory(AlwaysPassMatcherFactory.class)
SerializableMatcher<PipelineResult> getOnCreateMatcher()

setOnCreateMatcher

void setOnCreateMatcher(SerializableMatcher<PipelineResult> value)

getOnSuccessMatcher

@InstanceFactory(AlwaysPassMatcherFactory.class)
SerializableMatcher<PipelineResult> getOnSuccessMatcher()

setOnSuccessMatcher

void setOnSuccessMatcher(SerializableMatcher<PipelineResult> value)

getTestTimeoutSeconds

@Long(900L)
@Nullable Long getTestTimeoutSeconds()

setTestTimeoutSeconds

void setTestTimeoutSeconds(Long value)

isBlockOnRun

@Boolean(true)
boolean isBlockOnRun()

setBlockOnRun

void setBlockOnRun(boolean value)