Package org.apache.flink.table.gateway.service.operation

Class OperationExecutor

java.lang.Object

org.apache.flink.table.gateway.service.operation.OperationExecutor

public class OperationExecutor
extends Object

An executor to execute the Operation.

Field Summary

Fields

Modifier and Type	Field	Description
protected SessionContext	sessionContext

Constructor Summary

Constructors

Constructor	Description
OperationExecutor(SessionContext context, org.apache.flink.configuration.Configuration executionConfig)

Method Summary

Modifier and Type	Method	Description
protected ResultFetcher	callRemoveJar(org.apache.flink.table.gateway.api.operation.OperationHandle operationHandle, String jarPath)
ResultFetcher	callShowJobsOperation(org.apache.flink.table.api.internal.TableEnvironmentInternal tableEnv, org.apache.flink.table.gateway.api.operation.OperationHandle operationHandle, org.apache.flink.table.operations.command.ShowJobsOperation showJobsOperation)
ResultFetcher	callStopJobOperation(org.apache.flink.table.api.internal.TableEnvironmentInternal tableEnv, org.apache.flink.table.gateway.api.operation.OperationHandle handle, org.apache.flink.table.operations.command.StopJobOperation stopJobOperation)
ResultFetcher	configureSession(org.apache.flink.table.gateway.api.operation.OperationHandle handle, String statement)
ResultFetcher	executeStatement(org.apache.flink.table.gateway.api.operation.OperationHandle handle, String statement)
ResultFetcher	getCompletionHints(org.apache.flink.table.gateway.api.operation.OperationHandle operationHandle, String statement, int position)
String	getCurrentCatalog()
org.apache.flink.table.functions.FunctionDefinition	getFunctionDefinition(org.apache.flink.table.catalog.UnresolvedIdentifier identifier)
org.apache.flink.table.catalog.ResolvedCatalogBaseTable<?>	getTable(org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier)
org.apache.flink.table.api.internal.TableEnvironmentInternal	getTableEnvironment()
org.apache.flink.table.api.internal.TableEnvironmentInternal	getTableEnvironment(org.apache.flink.table.resource.ResourceManager resourceManager)
Set<String>	listCatalogs()
Set<String>	listDatabases(String catalogName)
Set<org.apache.flink.table.gateway.api.results.FunctionInfo>	listSystemFunctions()
Set<org.apache.flink.table.gateway.api.results.TableInfo>	listTables(String catalogName, String databaseName, Set<org.apache.flink.table.catalog.CatalogBaseTable.TableKind> tableKinds)
Set<org.apache.flink.table.gateway.api.results.FunctionInfo>	listUserDefinedFunctions(String catalogName, String databaseName)

Methods inherited from class java.lang.Object

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

Field Detail

sessionContext

protected final SessionContext sessionContext

Constructor Detail

OperationExecutor

@VisibleForTesting
public OperationExecutor(SessionContext context,
                         org.apache.flink.configuration.Configuration executionConfig)

Method Detail

configureSession

public ResultFetcher configureSession(org.apache.flink.table.gateway.api.operation.OperationHandle handle,
                                      String statement)

executeStatement

public ResultFetcher executeStatement(org.apache.flink.table.gateway.api.operation.OperationHandle handle,
                                      String statement)

getCurrentCatalog

public String getCurrentCatalog()

listCatalogs

public Set<String> listCatalogs()

listDatabases

public Set<String> listDatabases(String catalogName)

listTables

public Set<org.apache.flink.table.gateway.api.results.TableInfo> listTables(String catalogName,
                                                                            String databaseName,
                                                                            Set<org.apache.flink.table.catalog.CatalogBaseTable.TableKind> tableKinds)

getTable

public org.apache.flink.table.catalog.ResolvedCatalogBaseTable<?> getTable(org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier)

listUserDefinedFunctions

public Set<org.apache.flink.table.gateway.api.results.FunctionInfo> listUserDefinedFunctions(String catalogName,
                                                                                             String databaseName)

listSystemFunctions

public Set<org.apache.flink.table.gateway.api.results.FunctionInfo> listSystemFunctions()

getFunctionDefinition

public org.apache.flink.table.functions.FunctionDefinition getFunctionDefinition(org.apache.flink.table.catalog.UnresolvedIdentifier identifier)

getCompletionHints

public ResultFetcher getCompletionHints(org.apache.flink.table.gateway.api.operation.OperationHandle operationHandle,
                                        String statement,
                                        int position)

getTableEnvironment

public org.apache.flink.table.api.internal.TableEnvironmentInternal getTableEnvironment()

getTableEnvironment

public org.apache.flink.table.api.internal.TableEnvironmentInternal getTableEnvironment(org.apache.flink.table.resource.ResourceManager resourceManager)

callRemoveJar

protected ResultFetcher callRemoveJar(org.apache.flink.table.gateway.api.operation.OperationHandle operationHandle,
                                      String jarPath)

callStopJobOperation

public ResultFetcher callStopJobOperation(org.apache.flink.table.api.internal.TableEnvironmentInternal tableEnv,
                                          org.apache.flink.table.gateway.api.operation.OperationHandle handle,
                                          org.apache.flink.table.operations.command.StopJobOperation stopJobOperation)
                                   throws SqlExecutionException

Throws:

SqlExecutionException

callShowJobsOperation

public ResultFetcher callShowJobsOperation(org.apache.flink.table.api.internal.TableEnvironmentInternal tableEnv,
                                           org.apache.flink.table.gateway.api.operation.OperationHandle operationHandle,
                                           org.apache.flink.table.operations.command.ShowJobsOperation showJobsOperation)
                                    throws SqlExecutionException

Throws:

SqlExecutionException