Package org.apache.flink.core.execution
Interface PipelineExecutor
-
- All Known Subinterfaces:
CacheSupportedPipelineExecutor
@Internal public interface PipelineExecutorThe entity responsible for executing aPipeline, 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)
-
-
-
Method Detail
-
execute
CompletableFuture<JobClient> execute(Pipeline pipeline, Configuration configuration, ClassLoader userCodeClassloader) throws Exception
Executes aPipelinebased on the provided configuration and returns aJobClientwhich 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- thePipelineto executeconfiguration- theConfigurationwith the required execution parametersuserCodeClassloader- theClassLoaderto deserialize usercode- Returns:
- a
CompletableFuturewith theJobClientcorresponding to the pipeline. - Throws:
Exception
-
-