org.apache.flink.core.execution

Interface PipelineExecutor

All Known Subinterfaces:

CacheSupportedPipelineExecutor

All Known Implementing Classes:

AbstractJobClusterExecutor, AbstractSessionClusterExecutor, EmbeddedExecutor, KubernetesSessionClusterExecutor, LocalExecutor, RemoteExecutor, YarnJobClusterExecutor, YarnSessionClusterExecutor

@Internal
public interface PipelineExecutor

The entity responsible for executing a Pipeline, i.e. a user job.

Method Summary

Modifier and Type	Method and 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