PipelineExecutor (Flink : 2.0-SNAPSHOT API)

All Known Subinterfaces:

CacheSupportedPipelineExecutor

All Known Implementing Classes:

AbstractSessionClusterExecutor, EmbeddedExecutor, KubernetesSessionClusterExecutor, LocalExecutor, RemoteExecutor, YarnSessionClusterExecutor
```
@Internal
public interface PipelineExecutor
```
The entity responsible for executing a Pipeline, i.e. a user job.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`CompletableFuture<JobClient>`	`execute(Pipeline pipeline, Configuration configuration, ClassLoader userCodeClassloader)`	Executes a `Pipeline` based on the provided configuration and returns a `JobClient` which allows to interact with the job being executed, e.g. cancel it or take a savepoint.

- Method Detail
  - execute
```
CompletableFuture<JobClient> execute(Pipeline pipeline,
                                     Configuration configuration,
                                     ClassLoader userCodeClassloader)
                              throws Exception
```
    Executes a Pipeline based on the provided configuration and returns a JobClient which allows to interact with the job being executed, e.g. cancel it or take a savepoint.
    ATTENTION: The caller is responsible for managing the lifecycle of the returned JobClient. This means that e.g. close() should be called explicitly at the call-site.
    
    Parameters:
    
    pipeline - the Pipeline to execute
    
    configuration - the Configuration with the required execution parameters
    
    userCodeClassloader - the ClassLoader to deserialize usercode
    
    Returns:
    
    a CompletableFuture with the JobClient corresponding to the pipeline.
    
    Throws:
    
    Exception