public static class GcsOptions.ExecutorServiceFactory extends java.lang.Object implements DefaultValueFactory<java.util.concurrent.ExecutorService>
ExecutorService
to use within the Apache Beam SDK. The ExecutorService
is compatible with AppEngine.Constructor and Description |
---|
ExecutorServiceFactory() |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.ExecutorService |
create(PipelineOptions options)
Creates a default value for a getter marked with
Default.InstanceFactory . |
public java.util.concurrent.ExecutorService create(PipelineOptions options)
DefaultValueFactory
Default.InstanceFactory
.create
in interface DefaultValueFactory<java.util.concurrent.ExecutorService>
options
- The current pipeline options.