org.apache.flink.table.executor.python

Class ChainingOptimizingExecutor

java.lang.Object

org.apache.flink.table.executor.python.ChainingOptimizingExecutor

All Implemented Interfaces:

Executor

@Internal
public class ChainingOptimizingExecutor
extends Object
implements Executor

Executor which will perform chaining optimization before generating the StreamGraph.

Constructor Summary

Constructors

Constructor and Description
ChainingOptimizingExecutor(Executor executor)

Method Summary

Modifier and Type	Method and Description
Pipeline	createPipeline(List<Transformation<?>> transformations, ReadableConfig configuration, 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.
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

ChainingOptimizingExecutor

public ChainingOptimizingExecutor(Executor executor)

Method Detail

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 configuration,
                               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

configuration - 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.