public interface DirectOptions extends PipelineOptions, ApplicationNameOptions
DirectRunner
.Modifier and Type | Interface and Description |
---|---|
static class |
DirectOptions.AvailableParallelismFactory
A
DefaultValueFactory that returns the result of Runtime.availableProcessors()
from the DirectOptions.AvailableParallelismFactory.create(PipelineOptions) method. |
PipelineOptions.AtomicLongFactory, PipelineOptions.CheckEnabled, PipelineOptions.DirectRunner, PipelineOptions.JobNameFactory, PipelineOptions.UserAgentFactory
Modifier and Type | Method and Description |
---|---|
int |
getTargetParallelism() |
boolean |
isBlockOnRun() |
boolean |
isEnforceEncodability() |
boolean |
isEnforceImmutability() |
void |
setBlockOnRun(boolean b) |
void |
setEnforceEncodability(boolean test) |
void |
setEnforceImmutability(boolean test) |
void |
setTargetParallelism(int target) |
getAppName, setAppName
as, getJobName, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, setJobName, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent
populateDisplayData
@Default.Boolean(value=true) boolean isBlockOnRun()
void setBlockOnRun(boolean b)
@Default.Boolean(value=true) boolean isEnforceImmutability()
void setEnforceImmutability(boolean test)
@Default.Boolean(value=true) boolean isEnforceEncodability()
void setEnforceEncodability(boolean test)
@Default.InstanceFactory(value=DirectOptions.AvailableParallelismFactory.class) int getTargetParallelism()
void setTargetParallelism(int target)