@Internal public interface PipelineExecutor
Pipeline
, i.e. a user job.Modifier and Type | Method and Description |
---|---|
CompletableFuture<? extends JobClient> |
execute(Pipeline pipeline,
Configuration configuration)
|
CompletableFuture<? extends JobClient> execute(Pipeline pipeline, Configuration configuration) 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 parametersCompletableFuture
with the JobClient
corresponding to the pipeline.Exception
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.