org.apache.flink.table.planner.delegation

Class DefaultExecutor

java.lang.Object

org.apache.flink.table.planner.delegation.DefaultExecutor

All Implemented Interfaces:

Executor

@Internal
public class DefaultExecutor
extends Object
implements Executor

Default implementation of Executor.

Constructor Summary

Constructors

Constructor and Description
DefaultExecutor(StreamExecutionEnvironment executionEnvironment)

Method Summary

Modifier and Type	Method and Description
Pipeline	createPipeline(List<Transformation<?>> transformations, ReadableConfig tableConfiguration, String defaultJobName) Translates the given transformations 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.
StreamExecutionEnvironment	getExecutionEnvironment()
boolean	isCheckpointingEnabled() Checks whether checkpointing is enabled.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultExecutor

public DefaultExecutor(StreamExecutionEnvironment executionEnvironment)

Method Detail

getExecutionEnvironment

public StreamExecutionEnvironment getExecutionEnvironment()

getConfiguration

public ReadableConfig getConfiguration()

Description copied from interface: Executor

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

Specified by:

getConfiguration in interface Executor

createPipeline

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

Description copied from interface: Executor

Translates the given transformations to a Pipeline.

Specified by:

createPipeline in interface Executor

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.

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.

isCheckpointingEnabled

public boolean isCheckpointingEnabled()

Description copied from interface: Executor

Checks whether checkpointing is enabled.

Specified by:

isCheckpointingEnabled in interface Executor

Returns:

True if checkpointing is enables, false otherwise.