@Experimental(value=PORTABILITY) public interface PortablePipelineOptions extends PipelineOptions, FileStagingOptions
PipelineOptions.AtomicLongFactory, PipelineOptions.CheckEnabled, PipelineOptions.DirectRunner, PipelineOptions.JobNameFactory, PipelineOptions.UserAgentFactory
Modifier and Type | Method and 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) |
getFilesToStage, setFilesToStage
as, getJobName, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, setJobName, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent
populateDisplayData
@Validation.Required java.lang.String getJobEndpoint()
void setJobEndpoint(java.lang.String endpoint)
@Default.Integer(value=60) int getJobServerTimeout()
void setJobServerTimeout(int timeout)
@Nullable java.lang.String getDefaultEnvironmentType()
void setDefaultEnvironmentType(java.lang.String environmentType)
@Nullable java.lang.String getDefaultEnvironmentConfig()
void setDefaultEnvironmentConfig(@Nullable java.lang.String config)
@Default.Integer(value=1) int getSdkWorkerParallelism()
void setSdkWorkerParallelism(int parallelism)
@Default.Integer(value=0) int getEnvironmentCacheMillis()
void setEnvironmentCacheMillis(int environmentCacheMillis)
@Default.Integer(value=0) int getEnvironmentExpirationMillis()
void setEnvironmentExpirationMillis(int environmentExpirationMillis)
@Default.Boolean(value=false) boolean getLoadBalanceBundles()
void setLoadBalanceBundles(boolean loadBalanceBundles)
@Nullable java.lang.String getOutputExecutablePath()
void setOutputExecutablePath(java.lang.String outputExecutablePath)
java.util.List<java.lang.String> getEnvironmentOptions()
void setEnvironmentOptions(java.util.List<java.lang.String> value)
static java.lang.String getEnvironmentOption(PortablePipelineOptions options, java.lang.String environmentOptionName)