org.apache.beam.sdk.options

Interface PortablePipelineOptions

All Superinterfaces:

HasDisplayData, PipelineOptions

public interface PortablePipelineOptions
extends PipelineOptions

Pipeline options common to all portable runners.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.beam.sdk.options.PipelineOptions

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

Method Summary

Modifier and Type	Method and Description
java.lang.String	getDefaultJavaEnvironmentUrl()
java.util.List<java.lang.String>	getFilesToStage() List of local files to make available to workers.
java.lang.String	getJobEndpoint()
void	setDefaultJavaEnvironmentUrl(java.lang.String url)
void	setFilesToStage(java.util.List<java.lang.String> value)
void	setJobEndpoint(java.lang.String endpoint)

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

getFilesToStage

java.util.List<java.lang.String> getFilesToStage()

List of local files to make available to workers.

Files are placed on the worker's classpath.

The default value is the list of jars from the main program's classpath.

setFilesToStage

void setFilesToStage(java.util.List<java.lang.String> value)

getJobEndpoint

@Validation.Required
java.lang.String getJobEndpoint()

setJobEndpoint

void setJobEndpoint(java.lang.String endpoint)

getDefaultJavaEnvironmentUrl

java.lang.String getDefaultJavaEnvironmentUrl()

setDefaultJavaEnvironmentUrl

void setDefaultJavaEnvironmentUrl(java.lang.String url)