Package org.apache.beam.sdk.options

Interface ExecutorOptions

All Superinterfaces:

HasDisplayData, PipelineOptions

public interface ExecutorOptions
extends PipelineOptions

Options for configuring the ScheduledExecutorService used throughout the Java runtime.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	ExecutorOptions.ScheduledExecutorServiceFactory	Returns the default ScheduledExecutorService to use within the Apache Beam SDK.

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
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)

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

getScheduledExecutorService

@InstanceFactory(ScheduledExecutorServiceFactory.class)
@Hidden
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. If unset, the default is to create an UnboundedScheduledExecutorService.

setScheduledExecutorService

void setScheduledExecutorService(java.util.concurrent.ScheduledExecutorService value)