EmbeddedExecutorFactory (Flink : Clients 2.0.0-cp1 API)

java.lang.Object
- org.apache.flink.client.deployment.application.executors.EmbeddedExecutorFactory

All Implemented Interfaces:: org.apache.flink.core.execution.PipelineExecutorFactory

@Internal
public class EmbeddedExecutorFactory
extends Object
implements org.apache.flink.core.execution.PipelineExecutorFactory

An PipelineExecutorFactory for the EmbeddedExecutor.

Constructor Summary

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

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`org.apache.flink.core.execution.PipelineExecutor`	`getExecutor(org.apache.flink.configuration.Configuration configuration)`
`String`	`getName()`
`boolean`	`isCompatibleWith(org.apache.flink.configuration.Configuration configuration)`

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

- Constructor Detail
  - EmbeddedExecutorFactory
```
public EmbeddedExecutorFactory(Collection<org.apache.flink.api.common.JobID> submittedJobIds,
                               org.apache.flink.runtime.dispatcher.DispatcherGateway dispatcherGateway,
                               org.apache.flink.util.concurrent.ScheduledExecutor retryExecutor)
```
    Creates an EmbeddedExecutorFactory.
    
    Parameters:
    
    submittedJobIds - a list that is going to be filled 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
  - getName
```
public String getName()
```
    Specified by:
    
    getName in interface org.apache.flink.core.execution.PipelineExecutorFactory
  - isCompatibleWith
```
public boolean isCompatibleWith(org.apache.flink.configuration.Configuration configuration)
```
    Specified by:
    
    isCompatibleWith in interface org.apache.flink.core.execution.PipelineExecutorFactory
  - getExecutor
```
public org.apache.flink.core.execution.PipelineExecutor getExecutor(org.apache.flink.configuration.Configuration configuration)
```
    Specified by:
    
    getExecutor in interface org.apache.flink.core.execution.PipelineExecutorFactory