Package org.apache.flink.table.executor.python

Class ChainingOptimizingExecutor

java.lang.Object

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

All Implemented Interfaces:

org.apache.flink.table.delegation.Executor

@Internal
public class ChainingOptimizingExecutor
extends Object
implements org.apache.flink.table.delegation.Executor

Executor which will perform chaining optimization before generating the StreamGraph.

Constructor Summary

Constructors

Constructor	Description
ChainingOptimizingExecutor(org.apache.flink.table.delegation.Executor executor)

Method Summary

Modifier and Type	Method	Description
org.apache.flink.api.dag.Pipeline	createPipeline(List<org.apache.flink.api.dag.Transformation<?>> transformations, org.apache.flink.configuration.ReadableConfig configuration, String defaultJobName)
org.apache.flink.api.dag.Pipeline	createPipeline(List<org.apache.flink.api.dag.Transformation<?>> transformations, org.apache.flink.configuration.ReadableConfig configuration, String defaultJobName, List<org.apache.flink.core.execution.JobStatusHook> jobStatusHookList)
org.apache.flink.api.common.JobExecutionResult	execute(org.apache.flink.api.dag.Pipeline pipeline)
org.apache.flink.core.execution.JobClient	executeAsync(org.apache.flink.api.dag.Pipeline pipeline)
org.apache.flink.configuration.ReadableConfig	getConfiguration()
boolean	isCheckpointingEnabled()

Methods inherited from class java.lang.Object

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

Constructor Detail

ChainingOptimizingExecutor

public ChainingOptimizingExecutor(org.apache.flink.table.delegation.Executor executor)

Method Detail

getConfiguration

public org.apache.flink.configuration.ReadableConfig getConfiguration()

Specified by:

getConfiguration in interface org.apache.flink.table.delegation.Executor

createPipeline

public org.apache.flink.api.dag.Pipeline createPipeline(List<org.apache.flink.api.dag.Transformation<?>> transformations,
                                                        org.apache.flink.configuration.ReadableConfig configuration,
                                                        String defaultJobName)

Specified by:

createPipeline in interface org.apache.flink.table.delegation.Executor

createPipeline

public org.apache.flink.api.dag.Pipeline createPipeline(List<org.apache.flink.api.dag.Transformation<?>> transformations,
                                                        org.apache.flink.configuration.ReadableConfig configuration,
                                                        @Nullable
                                                        String defaultJobName,
                                                        List<org.apache.flink.core.execution.JobStatusHook> jobStatusHookList)

Specified by:

createPipeline in interface org.apache.flink.table.delegation.Executor

execute

public org.apache.flink.api.common.JobExecutionResult execute(org.apache.flink.api.dag.Pipeline pipeline)
                                                       throws Exception

Specified by:

execute in interface org.apache.flink.table.delegation.Executor

Throws:

Exception

executeAsync

public org.apache.flink.core.execution.JobClient executeAsync(org.apache.flink.api.dag.Pipeline pipeline)
                                                       throws Exception

Specified by:

executeAsync in interface org.apache.flink.table.delegation.Executor

Throws:

Exception

isCheckpointingEnabled

public boolean isCheckpointingEnabled()

Specified by:

isCheckpointingEnabled in interface org.apache.flink.table.delegation.Executor