org.apache.beam.runners.reference.testing

Interface TestPortablePipelineOptions

All Superinterfaces:

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.NoOpMetricsSink, PipelineOptions.UserAgentFactory

Field Summary

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

SDK_WORKER_PARALLELISM_PIPELINE, SDK_WORKER_PARALLELISM_STAGE

Method Summary

Modifier and Type	Method and Description
java.lang.String[]	getJobServerConfig()
java.lang.Class	getJobServerDriver()
void	setJobServerConfig(java.lang.String... jobServerConfig)
void	setJobServerDriver(java.lang.Class jobServerDriver)

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

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

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

getDefaultEnvironmentConfig, getDefaultEnvironmentType, getDefaultJavaEnvironmentUrl, getFilesToStage, getJobEndpoint, getSdkWorkerParallelism, setDefaultEnvironmentConfig, setDefaultEnvironmentType, setDefaultJavaEnvironmentUrl, setFilesToStage, setJobEndpoint, setSdkWorkerParallelism

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

as, getJobName, getMetricsHttpSinkUrl, getMetricsPushPeriod, getMetricsSink, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, setJobName, setMetricsHttpSinkUrl, setMetricsPushPeriod, setMetricsSink, 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 getJobServerDriver()

setJobServerDriver

void setJobServerDriver(java.lang.Class jobServerDriver)

getJobServerConfig

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

setJobServerConfig

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