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 and Description
protected SessionContext	sessionContext

Constructor Summary

Constructors

Constructor and Description
OperationExecutor(SessionContext context, Configuration executionConfig)

Method Summary

Modifier and Type	Method and Description
ResultFetcher	callDescribeJobOperation(TableEnvironmentInternal tableEnv, OperationHandle operationHandle, DescribeJobOperation describeJobOperation)
ResultFetcher	callExecutableOperation(OperationHandle handle, ExecutableOperation op)
protected ResultFetcher	callRemoveJar(OperationHandle operationHandle, String jarPath)
ResultFetcher	callShowJobsOperation(TableEnvironmentInternal tableEnv, OperationHandle operationHandle, ShowJobsOperation showJobsOperation)
ResultFetcher	callStopJobOperation(TableEnvironmentInternal tableEnv, OperationHandle handle, StopJobOperation stopJobOperation)
ResultFetcher	configureSession(OperationHandle handle, String statement)
ResultFetcher	executeStatement(OperationHandle handle, Configuration customConfig, String statement)
ResultFetcher	executeStatement(OperationHandle handle, String statement)
ResultFetcher	getCompletionHints(OperationHandle operationHandle, String statement, int position)
String	getCurrentCatalog()
FunctionDefinition	getFunctionDefinition(UnresolvedIdentifier identifier)
SessionContext	getSessionContext()
ResolvedCatalogBaseTable<?>	getTable(ObjectIdentifier tableIdentifier)
TableEnvironmentInternal	getTableEnvironment()
TableEnvironmentInternal	getTableEnvironment(ResourceManager resourceManager, Configuration customConfig)
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)
ResultFetcher	refreshMaterializedTable(OperationHandle handle, String materializedTableIdentifier, boolean isPeriodic, String scheduleTime, Map<String,String> staticPartitions, Map<String,String> dynamicOptions)
boolean	tableExists(ObjectIdentifier tableIdentifier)

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,
                                            Configuration executionConfig)

Method Detail

configureSession

public ResultFetcher configureSession(OperationHandle handle,
                                      String statement)

executeStatement

public ResultFetcher executeStatement(OperationHandle handle,
                                      String statement)

executeStatement

public ResultFetcher executeStatement(OperationHandle handle,
                                      Configuration customConfig,
                                      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)

tableExists

public boolean tableExists(ObjectIdentifier tableIdentifier)

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)

getCompletionHints

public ResultFetcher getCompletionHints(OperationHandle operationHandle,
                                        String statement,
                                        int position)

getTableEnvironment

public TableEnvironmentInternal getTableEnvironment()

getTableEnvironment

public TableEnvironmentInternal getTableEnvironment(ResourceManager resourceManager,
                                                    Configuration customConfig)

callExecutableOperation

public ResultFetcher callExecutableOperation(OperationHandle handle,
                                             ExecutableOperation op)

refreshMaterializedTable

public ResultFetcher refreshMaterializedTable(OperationHandle handle,
                                              String materializedTableIdentifier,
                                              boolean isPeriodic,
                                              @Nullable
                                              String scheduleTime,
                                              Map<String,String> staticPartitions,
                                              Map<String,String> dynamicOptions)

getSessionContext

public SessionContext getSessionContext()

callRemoveJar

protected ResultFetcher callRemoveJar(OperationHandle operationHandle,
                                      String jarPath)

callStopJobOperation

public ResultFetcher callStopJobOperation(TableEnvironmentInternal tableEnv,
                                          OperationHandle handle,
                                          StopJobOperation stopJobOperation)
                                   throws SqlExecutionException

Throws:

SqlExecutionException

callShowJobsOperation

public ResultFetcher callShowJobsOperation(TableEnvironmentInternal tableEnv,
                                           OperationHandle operationHandle,
                                           ShowJobsOperation showJobsOperation)
                                    throws SqlExecutionException

Throws:

SqlExecutionException

callDescribeJobOperation

public ResultFetcher callDescribeJobOperation(TableEnvironmentInternal tableEnv,
                                              OperationHandle operationHandle,
                                              DescribeJobOperation describeJobOperation)
                                       throws SqlExecutionException

Throws:

SqlExecutionException