Package org.apache.beam.runners.portability.testing

Interface TestUniversalRunner.Options

All Superinterfaces:

FileStagingOptions, HasDisplayData, PipelineOptions, PortablePipelineOptions, TestPipelineOptions

Enclosing class:

TestUniversalRunner

public static interface TestUniversalRunner.Options
extends TestPipelineOptions, PortablePipelineOptions

Nested Class Summary

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	getLocalJobServicePortFile()	A file containing the job service port, since Gradle needs to know this filename statically to provide it in Beam testing options.
void	setLocalJobServicePortFile(String endpoint)

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, getGbek, getJobName, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, revision, setGbek, 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

getLocalJobServicePortFile

String getLocalJobServicePortFile()

A file containing the job service port, since Gradle needs to know this filename statically to provide it in Beam testing options.

This option conflicts with PortablePipelineOptions.getJobEndpoint(). This option will override the job endpoint to be localhost at the port specified in the file.

setLocalJobServicePortFile

void setLocalJobServicePortFile(String endpoint)