@Internal public class BatchExecutor extends ExecutorBase
Executorthat is backed by a
StreamExecutionEnvironment. This is the only executor that
|Constructor and Description|
|Modifier and Type||Method and Description|
Translates the given transformations to a Pipeline.
execute, executeAsync, getExecutionEnvironment, getNonEmptyJobName
@VisibleForTesting public BatchExecutor(StreamExecutionEnvironment executionEnvironment)
public Pipeline createPipeline(List<Transformation<?>> transformations, TableConfig tableConfig, String jobName)
transformations- list of transformations
jobName- what should be the name of the job
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.