Package org.apache.beam.sdk.testing
Interface TestPipelineOptions
-
- All Superinterfaces:
HasDisplayData
,PipelineOptions
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 forPipelineResult
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
All Methods Instance Methods Abstract Methods Modifier and Type Method 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.transforms.display.HasDisplayData
populateDisplayData
-
Methods inherited from interface org.apache.beam.sdk.options.PipelineOptions
as, getJobName, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, setJobName, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent
-
-
-
-
Method Detail
-
getTempRoot
java.lang.String getTempRoot()
-
setTempRoot
void setTempRoot(java.lang.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 java.lang.Long getTestTimeoutSeconds()
-
setTestTimeoutSeconds
void setTestTimeoutSeconds(java.lang.Long value)
-
isBlockOnRun
@Boolean(true) boolean isBlockOnRun()
-
setBlockOnRun
void setBlockOnRun(boolean value)
-
-