public interface PortablePipelineOptions extends PipelineOptions
Modifier and Type | Interface and Description |
---|---|
static class |
PortablePipelineOptions.RetrievalServiceType
Enumeration of the different implementations of the artifact retrieval service.
|
PipelineOptions.AtomicLongFactory, PipelineOptions.CheckEnabled, PipelineOptions.DirectRunner, PipelineOptions.JobNameFactory, PipelineOptions.UserAgentFactory
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getDefaultEnvironmentConfig() |
java.lang.String |
getDefaultEnvironmentType() |
int |
getEnvironmentCacheMillis() |
int |
getEnvironmentExpirationMillis() |
java.util.List<java.lang.String> |
getFilesToStage()
List of local files to make available to workers.
|
java.lang.String |
getJobEndpoint() |
boolean |
getLoadBalanceBundles() |
java.lang.String |
getOutputExecutablePath() |
PortablePipelineOptions.RetrievalServiceType |
getRetrievalServiceType() |
int |
getSdkWorkerParallelism() |
void |
setDefaultEnvironmentConfig(java.lang.String config) |
void |
setDefaultEnvironmentType(java.lang.String environmentType) |
void |
setEnvironmentCacheMillis(int environmentCacheMillis) |
void |
setEnvironmentExpirationMillis(int environmentExpirationMillis) |
void |
setFilesToStage(java.util.List<java.lang.String> value) |
void |
setJobEndpoint(java.lang.String endpoint) |
void |
setLoadBalanceBundles(boolean loadBalanceBundles) |
void |
setOutputExecutablePath(java.lang.String outputExecutablePath) |
void |
setRetrievalServiceType(PortablePipelineOptions.RetrievalServiceType retrievalServiceType) |
void |
setSdkWorkerParallelism(int parallelism) |
as, getJobName, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, setJobName, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent
populateDisplayData
java.util.List<java.lang.String> getFilesToStage()
Files are placed on the worker's classpath.
The default value is the list of jars from the main program's classpath.
void setFilesToStage(java.util.List<java.lang.String> value)
@Validation.Required java.lang.String getJobEndpoint()
void setJobEndpoint(java.lang.String endpoint)
@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)
@Default.Enum(value="FILE_SYSTEM") PortablePipelineOptions.RetrievalServiceType getRetrievalServiceType()
void setRetrievalServiceType(PortablePipelineOptions.RetrievalServiceType retrievalServiceType)