public interface ExecutorOptions extends PipelineOptions
ScheduledExecutorService
used throughout the Java runtime.Modifier and Type | Interface and Description |
---|---|
static class |
ExecutorOptions.ScheduledExecutorServiceFactory
Returns the default
ScheduledExecutorService to use within the Apache Beam SDK. |
PipelineOptions.AtomicLongFactory, PipelineOptions.CheckEnabled, PipelineOptions.DirectRunner, PipelineOptions.JobNameFactory, PipelineOptions.UserAgentFactory
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.ScheduledExecutorService |
getScheduledExecutorService()
The
ScheduledExecutorService instance to use to create threads, can be overridden to
specify a ScheduledExecutorService that is compatible with the user's environment. |
void |
setScheduledExecutorService(java.util.concurrent.ScheduledExecutorService value) |
as, getJobName, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, revision, setJobName, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent
populateDisplayData
@Default.InstanceFactory(value=ExecutorOptions.ScheduledExecutorServiceFactory.class) @Hidden java.util.concurrent.ScheduledExecutorService getScheduledExecutorService()
ScheduledExecutorService
instance to use to create threads, can be overridden to
specify a ScheduledExecutorService
that is compatible with the user's environment. If
unset, the default is to create an UnboundedScheduledExecutorService
.void setScheduledExecutorService(java.util.concurrent.ScheduledExecutorService value)