@Internal public class CollectionPipelineExecutor extends Object implements PipelineExecutor
PipelineExecutor
for serial, local, collection-based executions of Flink programs.Constructor and Description |
---|
CollectionPipelineExecutor() |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobClient> |
execute(Pipeline pipeline,
Configuration configuration)
|
public static final String NAME
public CompletableFuture<JobClient> execute(Pipeline pipeline, Configuration configuration) throws Exception
PipelineExecutor
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.
execute
in interface PipelineExecutor
pipeline
- the Pipeline
to executeconfiguration
- the Configuration
with the required execution parametersCompletableFuture
with the JobClient
corresponding to the pipeline.Exception
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.