@Internal public interface PipelineExecutor
Pipeline, i.e. a user job.
CompletableFuture<JobClient> execute(Pipeline pipeline, Configuration configuration) throws Exception
Pipelinebased on the provided configuration and returns a
JobClientwhich 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
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.