EmbeddedExecutorServiceLoader (Flink : Clients 1.18.1-cp5 API)

java.lang.Object
- org.apache.flink.client.deployment.application.executors.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 Summary

Constructors
Constructor	Description
`EmbeddedExecutorServiceLoader(Collection<org.apache.flink.api.common.JobID> submittedJobIds, org.apache.flink.runtime.dispatcher.DispatcherGateway dispatcherGateway, org.apache.flink.util.concurrent.ScheduledExecutor retryExecutor)`	Creates an `EmbeddedExecutorServiceLoader`.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`org.apache.flink.core.execution.PipelineExecutorFactory`	`getExecutorFactory(org.apache.flink.configuration.Configuration configuration)`
`java.util.stream.Stream<String>`	`getExecutorNames()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- 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)
```
    Creates an EmbeddedExecutorServiceLoader.
    
    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