Package org.apache.beam.sdk.options
Class ExecutorOptions.ScheduledExecutorServiceFactory
- java.lang.Object
-
- org.apache.beam.sdk.options.ExecutorOptions.ScheduledExecutorServiceFactory
-
- All Implemented Interfaces:
DefaultValueFactory<java.util.concurrent.ScheduledExecutorService>
- Enclosing interface:
- ExecutorOptions
public static class ExecutorOptions.ScheduledExecutorServiceFactory extends java.lang.Object implements DefaultValueFactory<java.util.concurrent.ScheduledExecutorService>
Returns the defaultScheduledExecutorService
to use within the Apache Beam SDK.
-
-
Constructor Summary
Constructors Constructor Description ScheduledExecutorServiceFactory()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.concurrent.ScheduledExecutorService
create(PipelineOptions options)
Creates a default value for a getter marked withDefault.InstanceFactory
.
-
-
-
Method Detail
-
create
public java.util.concurrent.ScheduledExecutorService create(PipelineOptions options)
Description copied from interface:DefaultValueFactory
Creates a default value for a getter marked withDefault.InstanceFactory
.- Specified by:
create
in interfaceDefaultValueFactory<java.util.concurrent.ScheduledExecutorService>
- Parameters:
options
- The current pipeline options.- Returns:
- The default value to be used for the annotated getter.
-
-