org.apache.flink.table.delegation

Interface Executor

All Known Implementing Classes:

ChainingOptimizingExecutor, DefaultExecutor

@Internal
public interface Executor

It enables the execution of a graph of Transformations generated by the Planner.

This uncouples the TableEnvironment from any given runtime.

Note that not every table program calls createPipeline(List, ReadableConfig, String) or execute(Pipeline). When bridging to DataStream API, this interface serves as a communication layer to the final pipeline executor via StreamExecutionEnvironment.

See Also:

ExecutorFactory

Method Summary

Modifier and Type	Method and Description
Pipeline	createPipeline(List<Transformation<?>> transformations, ReadableConfig tableConfiguration, String defaultJobName) Translates the given transformations to a Pipeline.
Pipeline	createPipeline(List<Transformation<?>> transformations, ReadableConfig tableConfiguration, String defaultJobName, List<JobStatusHook> jobStatusHookList) Translates the given transformations with a list of JobStatusHooks to a Pipeline.
JobExecutionResult	execute(Pipeline pipeline) Executes the given pipeline.
JobClient	executeAsync(Pipeline pipeline) Executes the given pipeline asynchronously.
ReadableConfig	getConfiguration() Gives read-only access to the configuration of the executor.
boolean	isCheckpointingEnabled() Checks whether checkpointing is enabled.

Method Detail

getConfiguration

ReadableConfig getConfiguration()

Gives read-only access to the configuration of the executor.

createPipeline

Pipeline createPipeline(List<Transformation<?>> transformations,
                        ReadableConfig tableConfiguration,
                        @Nullable
                        String defaultJobName)

Translates the given transformations to a Pipeline.

Parameters:

transformations - list of transformations

tableConfiguration - table-specific configuration options

defaultJobName - default job name if not specified via PipelineOptions.NAME

Returns:

The pipeline representing the transformations.

createPipeline

Pipeline createPipeline(List<Transformation<?>> transformations,
                        ReadableConfig tableConfiguration,
                        @Nullable
                        String defaultJobName,
                        List<JobStatusHook> jobStatusHookList)

Translates the given transformations with a list of JobStatusHooks to a Pipeline.

Parameters:

transformations - list of transformations

tableConfiguration - table-specific configuration options

defaultJobName - default job name if not specified via PipelineOptions.NAME

jobStatusHookList - list of JobStatusHooks

Returns:

The pipeline representing the transformations.

execute

JobExecutionResult execute(Pipeline pipeline)
                    throws Exception

Executes the given pipeline.

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

JobClient executeAsync(Pipeline pipeline)
                throws Exception

Executes the given pipeline asynchronously.

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.

isCheckpointingEnabled

boolean isCheckpointingEnabled()

Checks whether checkpointing is enabled.

Returns:

True if checkpointing is enables, false otherwise.