Class 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 default ScheduledExecutorService to use within the Apache Beam SDK.
    • Constructor Detail

      • ScheduledExecutorServiceFactory

        public ScheduledExecutorServiceFactory()
    • Method Detail

      • create

        public java.util.concurrent.ScheduledExecutorService create​(PipelineOptions options)
        Description copied from interface: DefaultValueFactory
        Creates a default value for a getter marked with Default.InstanceFactory.
        Specified by:
        create in interface DefaultValueFactory<java.util.concurrent.ScheduledExecutorService>
        Parameters:
        options - The current pipeline options.
        Returns:
        The default value to be used for the annotated getter.