org.apache.flink.table.planner.delegation.hive

Class HiveOperationExecutor

java.lang.Object

org.apache.flink.table.planner.delegation.hive.HiveOperationExecutor

All Implemented Interfaces:

ExtendedOperationExecutor

public class HiveOperationExecutor
extends Object
implements ExtendedOperationExecutor

A Hive's operation executor used to execute operation in custom way instead of Flink's implementation.

Constructor Summary

Constructors

Constructor and Description
HiveOperationExecutor(CatalogManager catalogManager, PlannerContext plannerContext)

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

HiveOperationExecutor

public HiveOperationExecutor(CatalogManager catalogManager,
                             PlannerContext plannerContext)

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