Class EmbeddedExecutorServiceLoader

  • All Implemented Interfaces:
    org.apache.flink.core.execution.PipelineExecutorServiceLoader

    @Internal
    public class EmbeddedExecutorServiceLoader
    extends Object
    implements org.apache.flink.core.execution.PipelineExecutorServiceLoader
    A PipelineExecutorServiceLoader that always returns an EmbeddedExecutorFactory. This is useful when running the user's main on the cluster.
    • Constructor Detail

      • EmbeddedExecutorServiceLoader

        public EmbeddedExecutorServiceLoader​(Collection<org.apache.flink.api.common.JobID> submittedJobIds,
                                             org.apache.flink.runtime.dispatcher.DispatcherGateway dispatcherGateway,
                                             org.apache.flink.util.concurrent.ScheduledExecutor retryExecutor)
        Parameters:
        submittedJobIds - a list that is going to be filled by the EmbeddedExecutor with the job ids of the new jobs that will be submitted. This is essentially used to return the submitted job ids to the caller.
        dispatcherGateway - the dispatcher of the cluster which is going to be used to submit jobs.
    • Method Detail

      • getExecutorFactory

        public org.apache.flink.core.execution.PipelineExecutorFactory getExecutorFactory​(org.apache.flink.configuration.Configuration configuration)
        Specified by:
        getExecutorFactory in interface org.apache.flink.core.execution.PipelineExecutorServiceLoader
      • getExecutorNames

        public java.util.stream.Stream<String> getExecutorNames()
        Specified by:
        getExecutorNames in interface org.apache.flink.core.execution.PipelineExecutorServiceLoader