PipelineExecutorFactory (Flink : 2.0-SNAPSHOT API)

All Known Implementing Classes:

EmbeddedExecutorFactory, KubernetesSessionClusterExecutorFactory, LocalExecutorFactory, RemoteExecutorFactory, WebSubmissionExecutorFactory, YarnJobClusterExecutorFactory, YarnSessionClusterExecutorFactory
```
@Internal
public interface PipelineExecutorFactory
```
A factory for selecting and instantiating the adequate PipelineExecutor based on a provided Configuration.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`PipelineExecutor`	`getExecutor(Configuration configuration)`	Instantiates an `PipelineExecutor` compatible with the provided configuration.
`String`	`getName()`	Returns the name of the executor that this factory creates.
`boolean`	`isCompatibleWith(Configuration configuration)`	Returns `true` if this factory is compatible with the options in the provided configuration, `false` otherwise.

- Method Detail
  - getName
```
String getName()
```
    Returns the name of the executor that this factory creates.
  - isCompatibleWith
```
boolean isCompatibleWith(Configuration configuration)
```
    Returns true if this factory is compatible with the options in the provided configuration, false otherwise.
  - getExecutor
```
PipelineExecutor getExecutor(Configuration configuration)
```
    Instantiates an PipelineExecutor compatible with the provided configuration.
    
    Returns:
    
    the executor instance.