@Internal public interface PipelineExecutor
Pipeline
, i.e. a user job.Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobClient> |
execute(Pipeline pipeline,
Configuration configuration,
ClassLoader userCodeClassloader)
|
CompletableFuture<JobClient> execute(Pipeline pipeline, Configuration configuration, ClassLoader userCodeClassloader) throws Exception
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.
pipeline
- the Pipeline
to executeconfiguration
- the Configuration
with the required execution parametersuserCodeClassloader
- the ClassLoader
to deserialize usercodeCompletableFuture
with the JobClient
corresponding to the pipeline.Exception
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.