org.apache.flink.table.delegation

Interface ExtendedOperationExecutor

All Known Implementing Classes:

DialectFactory.EmptyOperationExecutor, HiveOperationExecutor

@Internal
public interface ExtendedOperationExecutor

An extended operation executor which provides method for executing operation. External pluggable dialect can implement this interface to execute operation in its own way instead of using Flink's own implementation for operation execution.

Method Summary

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

Method Detail

executeOperation

Optional<TableResultInternal> executeOperation(Operation operation)

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.