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

Class HiveOperationExecutor

java.lang.Object

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

public class HiveOperationExecutor
extends Object

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

Constructor Summary

Constructors

Constructor and Description
HiveOperationExecutor(ExecutableOperation.Context context)

Method Summary

Modifier and Type	Method and Description
Optional<TableResultInternal>	executeOperation(Operation operation)

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveOperationExecutor

public HiveOperationExecutor(ExecutableOperation.Context context)

Method Detail

executeOperation

public Optional<TableResultInternal> executeOperation(Operation operation)