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

Class OperationExecutor

  • public class OperationExecutor
extends Object
    An executor to execute the Operation.

    • Constructor Detail

      • OperationExecutor

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

      • OperationExecutor

        public OperationExecutor​(SessionContext sessionContext,
                         BiFunction<org.apache.flink.configuration.Configuration,​ClassLoader,​org.apache.flink.streaming.api.environment.StreamExecutionEnvironment> environmentBuilder)

    • 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)

      • executeStatement

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

      • getCurrentCatalog

        public String getCurrentCatalog()

      • listCatalogs

        public Set<String> listCatalogs()

      • 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)

      • tableExists

        public boolean tableExists​(org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier)

      • 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,
                                                                                        org.apache.flink.configuration.Configuration customConfig)

      • getSessionClusterId

        public <ClusterID> Optional<String> getSessionClusterId()

      • callExecutableOperation

        public ResultFetcher callExecutableOperation​(org.apache.flink.table.gateway.api.operation.OperationHandle handle,
                                             org.apache.flink.table.operations.ExecutableOperation op)

      • refreshMaterializedTable

        public ResultFetcher refreshMaterializedTable​(org.apache.flink.table.gateway.api.operation.OperationHandle handle,
                                              String materializedTableIdentifier,
                                              boolean isPeriodic,
                                              @Nullable
                                              String scheduleTime,
                                              Map<String,​String> staticPartitions,
                                              Map<String,​String> dynamicOptions)

      • 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

      • callDescribeJobOperation

        public ResultFetcher callDescribeJobOperation​(org.apache.flink.table.api.internal.TableEnvironmentInternal tableEnv,
                                              org.apache.flink.table.gateway.api.operation.OperationHandle operationHandle,
                                              org.apache.flink.table.operations.command.DescribeJobOperation describeJobOperation)
                                       throws SqlExecutionException
        Throws:
        SqlExecutionException