org.apache.beam.runners.portability.testing

Interface TestPortablePipelineOptions

All Superinterfaces:

FileStagingOptions, HasDisplayData, PipelineOptions, PortablePipelineOptions, TestPipelineOptions

public interface TestPortablePipelineOptions
extends TestPipelineOptions, PortablePipelineOptions

Options for TestPortableRunner.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	TestPortablePipelineOptions.DefaultJobServerConfigFactory Factory for default config.
static class	TestPortablePipelineOptions.TestPortablePipelineOptionsRegistrar Register TestPortablePipelineOptions.

Nested classes/interfaces inherited from interface org.apache.beam.sdk.testing.TestPipelineOptions

TestPipelineOptions.AlwaysPassMatcher, TestPipelineOptions.AlwaysPassMatcherFactory

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
java.lang.String[]	getJobServerConfig()
java.lang.Class<JobServerDriver>	getJobServerDriver()
void	setJobServerConfig(java.lang.String... jobServerConfig)
void	setJobServerDriver(java.lang.Class<JobServerDriver> jobServerDriver)

Methods inherited from interface org.apache.beam.sdk.testing.TestPipelineOptions

getOnCreateMatcher, getOnSuccessMatcher, getTempRoot, getTestTimeoutSeconds, isBlockOnRun, setBlockOnRun, setOnCreateMatcher, setOnSuccessMatcher, setTempRoot, setTestTimeoutSeconds

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

getDefaultEnvironmentConfig, getDefaultEnvironmentType, getEnableHeapDumps, getEnvironmentCacheMillis, getEnvironmentExpirationMillis, getEnvironmentOption, getEnvironmentOptions, getJobEndpoint, getJobServerTimeout, getLoadBalanceBundles, getOutputExecutablePath, getSdkWorkerParallelism, setDefaultEnvironmentConfig, setDefaultEnvironmentType, setEnableHeapDumps, setEnvironmentCacheMillis, setEnvironmentExpirationMillis, setEnvironmentOptions, setJobEndpoint, setJobServerTimeout, setLoadBalanceBundles, setOutputExecutablePath, setSdkWorkerParallelism

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

getFilesToStage, setFilesToStage

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

getJobServerDriver

@Validation.Required
java.lang.Class<JobServerDriver> getJobServerDriver()

setJobServerDriver

void setJobServerDriver(java.lang.Class<JobServerDriver> jobServerDriver)

getJobServerConfig

@Default.InstanceFactory(value=TestPortablePipelineOptions.DefaultJobServerConfigFactory.class)
java.lang.String[] getJobServerConfig()

setJobServerConfig

void setJobServerConfig(java.lang.String... jobServerConfig)