org.apache.flink.table.planner.delegation

Class DialectFactory.EmptyOperationExecutor

java.lang.Object

org.apache.flink.table.planner.delegation.DialectFactory.EmptyOperationExecutor

All Implemented Interfaces:

ExtendedOperationExecutor

Enclosing interface:

DialectFactory

public static class DialectFactory.EmptyOperationExecutor
extends Object
implements ExtendedOperationExecutor

Default implementation for ExtendedOperationExecutor that doesn't extend any operation behavior but forward all operations to the Flink planner.

Constructor Summary

Constructors

Constructor and Description
EmptyOperationExecutor()

Method Summary

Modifier and Type	Method and Description
Optional<TableResultInternal>	executeOperation(Operation operation) Execute the given operation and return the execution result.

Methods inherited from class java.lang.Object

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

Constructor Detail

EmptyOperationExecutor

public EmptyOperationExecutor()

Method Detail

executeOperation

public Optional<TableResultInternal> executeOperation(Operation operation)

Description copied from interface: ExtendedOperationExecutor

Execute the given operation and return the execution result. This method will delegate Flink's own operation execution.

If return Optional.empty(), the operation will then fall to Flink's operation execution.

Specified by:

executeOperation in interface ExtendedOperationExecutor