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