org.apache.flink.table.planner.delegation

Class ExecutorBase

java.lang.Object

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

All Implemented Interfaces:

Executor

Direct Known Subclasses:

BatchExecutor, StreamExecutor

@Internal
public abstract class ExecutorBase
extends Object
implements Executor

An implementation of Executor that is backed by a StreamExecutionEnvironment.

Field Summary

Fields

Modifier and Type	Field and Description
protected TableConfig	tableConfig

Constructor Summary

Constructors

Constructor and Description
ExecutorBase(StreamExecutionEnvironment executionEnvironment)

Method Summary

Modifier and Type	Method and Description
JobExecutionResult	execute(Pipeline pipeline) Executes the given pipeline.
JobClient	executeAsync(Pipeline pipeline) Executes the given pipeline asynchronously.
StreamExecutionEnvironment	getExecutionEnvironment()
protected String	getNonEmptyJobName(String jobName)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.table.delegation.Executor

createPipeline

Field Detail

tableConfig

protected TableConfig tableConfig

Constructor Detail

ExecutorBase

public ExecutorBase(StreamExecutionEnvironment executionEnvironment)

Method Detail

getExecutionEnvironment

public StreamExecutionEnvironment getExecutionEnvironment()

execute

public JobExecutionResult execute(Pipeline pipeline)
                           throws Exception

Description copied from interface: Executor

Executes the given pipeline.

Specified by:

execute in interface Executor

Parameters:

pipeline - the pipeline to execute

Returns:

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

Throws:

Exception - which occurs during job execution.

executeAsync

public JobClient executeAsync(Pipeline pipeline)
                       throws Exception

Description copied from interface: Executor

Executes the given pipeline asynchronously.

Specified by:

executeAsync in interface Executor

Parameters:

pipeline - the pipeline to execute

Returns:

A JobClient that can be used to communicate with the submitted job, completed on submission succeeded.

Throws:

Exception - which occurs during job execution.

getNonEmptyJobName

protected String getNonEmptyJobName(String jobName)