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.

Constructor Summary

Constructors

Constructor and Description
OperationExecutor(SessionContext context, Configuration executionConfig)

Method Summary

Modifier and Type	Method and Description
ResultFetcher	executeStatement(OperationHandle handle, String statement)
String	getCurrentCatalog()
FunctionDefinition	getFunctionDefinition(UnresolvedIdentifier identifier)
ResolvedCatalogBaseTable<?>	getTable(ObjectIdentifier tableIdentifier)
TableEnvironmentInternal	getTableEnvironment()
Set<String>	listCatalogs()
Set<String>	listDatabases(String catalogName)
Set<FunctionInfo>	listSystemFunctions()
Set<TableInfo>	listTables(String catalogName, String databaseName, Set<CatalogBaseTable.TableKind> tableKinds)
Set<FunctionInfo>	listUserDefinedFunctions(String catalogName, String databaseName)

Methods inherited from class java.lang.Object

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

Constructor Detail

OperationExecutor

@VisibleForTesting
public OperationExecutor(SessionContext context,
                                            Configuration executionConfig)

Method Detail

executeStatement

public ResultFetcher executeStatement(OperationHandle handle,
                                      String statement)

getCurrentCatalog

public String getCurrentCatalog()

listCatalogs

public Set<String> listCatalogs()

listDatabases

public Set<String> listDatabases(String catalogName)

listTables

public Set<TableInfo> listTables(String catalogName,
                                 String databaseName,
                                 Set<CatalogBaseTable.TableKind> tableKinds)

getTable

public ResolvedCatalogBaseTable<?> getTable(ObjectIdentifier tableIdentifier)

listUserDefinedFunctions

public Set<FunctionInfo> listUserDefinedFunctions(String catalogName,
                                                  String databaseName)

listSystemFunctions

public Set<FunctionInfo> listSystemFunctions()

getFunctionDefinition

public FunctionDefinition getFunctionDefinition(UnresolvedIdentifier identifier)

getTableEnvironment

@VisibleForTesting
public TableEnvironmentInternal getTableEnvironment()