Package 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	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.options.PipelineOptions

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

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

TestPipelineOptions.AlwaysPassMatcher, TestPipelineOptions.AlwaysPassMatcherFactory

Method Summary

Modifier and Type	Method	Description
String[]	getJobServerConfig()
Class<JobServerDriver>	getJobServerDriver()
void	setJobServerConfig(String... jobServerConfig)
void	setJobServerDriver(Class<JobServerDriver> jobServerDriver)

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

getFilesToStage, setFilesToStage

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, revision, setJobName, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent

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

getDefaultEnvironmentConfig, getDefaultEnvironmentType, getEnableHeapDumps, getEnvironmentCacheMillis, getEnvironmentExpirationMillis, 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.testing.TestPipelineOptions

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

Method Details

getJobServerDriver

@Required
Class<JobServerDriver> getJobServerDriver()

setJobServerDriver

void setJobServerDriver(Class<JobServerDriver> jobServerDriver)

getJobServerConfig

@InstanceFactory(DefaultJobServerConfigFactory.class)
String[] getJobServerConfig()

setJobServerConfig

void setJobServerConfig(String... jobServerConfig)