Package org.apache.beam.sdk.options

Interface PortablePipelineOptions

All Superinterfaces:

FileStagingOptions, HasDisplayData, PipelineOptions

@Experimental(PORTABILITY)
public interface PortablePipelineOptions
extends PipelineOptions, FileStagingOptions

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.UserAgentFactory

Method Summary

Modifier and Type	Method	Description
@Nullable java.lang.String	getDefaultEnvironmentConfig()
@Nullable java.lang.String	getDefaultEnvironmentType()
int	getEnvironmentCacheMillis()
int	getEnvironmentExpirationMillis()
static java.lang.String	getEnvironmentOption(PortablePipelineOptions options, java.lang.String environmentOptionName)	Return the value for the specified environment option or empty string if not present.
java.util.List<java.lang.String>	getEnvironmentOptions()
java.lang.String	getJobEndpoint()
int	getJobServerTimeout()
boolean	getLoadBalanceBundles()
@Nullable java.lang.String	getOutputExecutablePath()
int	getSdkWorkerParallelism()
void	setDefaultEnvironmentConfig(@Nullable java.lang.String config)
void	setDefaultEnvironmentType(java.lang.String environmentType)
void	setEnvironmentCacheMillis(int environmentCacheMillis)
void	setEnvironmentExpirationMillis(int environmentExpirationMillis)
void	setEnvironmentOptions(java.util.List<java.lang.String> value)
void	setJobEndpoint(java.lang.String endpoint)
void	setJobServerTimeout(int timeout)
void	setLoadBalanceBundles(boolean loadBalanceBundles)
void	setOutputExecutablePath(java.lang.String outputExecutablePath)
void	setSdkWorkerParallelism(int parallelism)

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

Method Detail

getJobEndpoint

@Required
java.lang.String getJobEndpoint()

setJobEndpoint

void setJobEndpoint(java.lang.String endpoint)

getJobServerTimeout

@Integer(60)
int getJobServerTimeout()

setJobServerTimeout

void setJobServerTimeout(int timeout)

getDefaultEnvironmentType

@Nullable java.lang.String getDefaultEnvironmentType()

setDefaultEnvironmentType

void setDefaultEnvironmentType(java.lang.String environmentType)

getDefaultEnvironmentConfig

@Nullable java.lang.String getDefaultEnvironmentConfig()

setDefaultEnvironmentConfig

void setDefaultEnvironmentConfig(@Nullable java.lang.String config)

getSdkWorkerParallelism

@Integer(1)
int getSdkWorkerParallelism()

setSdkWorkerParallelism

void setSdkWorkerParallelism(int parallelism)

getEnvironmentCacheMillis

@Integer(0)
int getEnvironmentCacheMillis()

setEnvironmentCacheMillis

void setEnvironmentCacheMillis(int environmentCacheMillis)

getEnvironmentExpirationMillis

@Integer(0)
int getEnvironmentExpirationMillis()

setEnvironmentExpirationMillis

void setEnvironmentExpirationMillis(int environmentExpirationMillis)

getLoadBalanceBundles

@Boolean(false)
boolean getLoadBalanceBundles()

setLoadBalanceBundles

void setLoadBalanceBundles(boolean loadBalanceBundles)

getOutputExecutablePath

@Nullable java.lang.String getOutputExecutablePath()

setOutputExecutablePath

void setOutputExecutablePath(java.lang.String outputExecutablePath)

getEnvironmentOptions

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

setEnvironmentOptions

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

getEnvironmentOption

static java.lang.String getEnvironmentOption(PortablePipelineOptions options,
                                             java.lang.String environmentOptionName)

Return the value for the specified environment option or empty string if not present.