@Internal public interface Executor
Transformation
s graph generated by Planner
.
This uncouples the TableEnvironment
from any given runtime.
Modifier and Type | Method and Description |
---|---|
Pipeline |
createPipeline(List<Transformation<?>> transformations,
TableConfig tableConfig,
String jobName)
Translates the given transformations to a Pipeline.
|
JobExecutionResult |
execute(Pipeline pipeline)
Executes the given pipeline.
|
JobClient |
executeAsync(Pipeline pipeline)
Executes the given pipeline asynchronously.
|
Pipeline createPipeline(List<Transformation<?>> transformations, TableConfig tableConfig, String jobName)
transformations
- list of transformationsjobName
- what should be the name of the jobJobExecutionResult execute(Pipeline pipeline) throws Exception
pipeline
- the pipeline to executeException
- which occurs during job execution.Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.