org.apache.flink.table.planner.delegation

Class BatchExecutor

java.lang.Object

org.apache.flink.table.planner.delegation.ExecutorBase

org.apache.flink.table.planner.delegation.BatchExecutor

All Implemented Interfaces:

Executor

@Internal
public class BatchExecutor
extends ExecutorBase

An implementation of Executor that is backed by a StreamExecutionEnvironment. This is the only executor that BatchPlanner supports.

Field Summary

Fields inherited from class org.apache.flink.table.planner.delegation.ExecutorBase

tableConfig

Constructor Summary

Constructors

Constructor and Description
BatchExecutor(StreamExecutionEnvironment executionEnvironment)

Method Summary

Modifier and Type	Method and Description
JobExecutionResult	execute(String jobName) Executes all the previously applied transformations via Executor.apply(List).
StreamGraph	getStreamGraph(String jobName) Translates the transformations applied into this executor to a stream graph.

Methods inherited from class org.apache.flink.table.planner.delegation.ExecutorBase

apply, getExecutionEnvironment, getNonEmptyJobName, setTableConfig

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BatchExecutor

@VisibleForTesting
public BatchExecutor(StreamExecutionEnvironment executionEnvironment)

Method Detail

execute

public JobExecutionResult execute(String jobName)
                           throws Exception

Description copied from interface: Executor

Executes all the previously applied transformations via Executor.apply(List).

Parameters:

jobName - what should be the name of the job

Returns:

The result of the job execution, containing elapsed time and accumulators.

Throws:

Exception - which occurs during job execution.

getStreamGraph

public StreamGraph getStreamGraph(String jobName)

Description copied from class: ExecutorBase

Translates the transformations applied into this executor to a stream graph.

Specified by:

getStreamGraph in class ExecutorBase