Uses of Interface
org.apache.flink.table.gateway.api.SqlGatewayService

Packages that use SqlGatewayService

Package	Description
org.apache.flink.table.endpoint.hive
org.apache.flink.table.endpoint.hive.util
org.apache.flink.table.gateway.api.endpoint
org.apache.flink.table.gateway.rest
org.apache.flink.table.gateway.rest.handler
org.apache.flink.table.gateway.rest.handler.materializedtable
org.apache.flink.table.gateway.rest.handler.materializedtable.scheduler
org.apache.flink.table.gateway.rest.handler.operation
org.apache.flink.table.gateway.rest.handler.session
org.apache.flink.table.gateway.rest.handler.statement
org.apache.flink.table.gateway.rest.handler.util
org.apache.flink.table.gateway.service

Uses of SqlGatewayService in org.apache.flink.table.endpoint.hive

Constructors in org.apache.flink.table.endpoint.hive with parameters of type SqlGatewayService

Constructor and Description
HiveServer2Endpoint(SqlGatewayService service, InetSocketAddress socketAddress, long maxMessageSize, int requestTimeoutMs, int backOffSlotLengthMs, int minWorkerThreads, int maxWorkerThreads, Duration workerKeepAliveTime, String catalogName, HiveConf hiveConf, String defaultDatabase, String moduleName)
HiveServer2Endpoint(SqlGatewayService service, InetSocketAddress socketAddress, long maxMessageSize, int requestTimeoutMs, int backOffSlotLengthMs, int minWorkerThreads, int maxWorkerThreads, Duration workerKeepAliveTime, String catalogName, HiveConf hiveConf, String defaultDatabase, String moduleName, boolean allowEmbedded, boolean isVerbose)

Uses of SqlGatewayService in org.apache.flink.table.endpoint.hive.util

Methods in org.apache.flink.table.endpoint.hive.util with parameters of type SqlGatewayService

Modifier and Type	Method and Description
static Callable<ResultSet>	OperationExecutorFactory.createGetCatalogsExecutor(SqlGatewayService service, SessionHandle sessionHandle)
static Callable<ResultSet>	OperationExecutorFactory.createGetColumnsExecutor(SqlGatewayService service, SessionHandle sessionHandle, String catalogName, String schemaName, String tableName, String columnsName)
static Callable<ResultSet>	OperationExecutorFactory.createGetFunctionsExecutor(SqlGatewayService service, SessionHandle sessionHandle, String catalogName, String databasePattern, String functionNamePattern)
static Callable<ResultSet>	OperationExecutorFactory.createGetPrimaryKeys(SqlGatewayService service, SessionHandle sessionHandle, String catalogName, String schemaName, String tableName)
static Callable<ResultSet>	OperationExecutorFactory.createGetSchemasExecutor(SqlGatewayService service, SessionHandle sessionHandle, String catalogName, String schemaName)
static Callable<ResultSet>	OperationExecutorFactory.createGetTablesExecutor(SqlGatewayService service, SessionHandle sessionHandle, String catalogName, String schemaName, String tableName, Set<CatalogBaseTable.TableKind> tableKinds)

Uses of SqlGatewayService in org.apache.flink.table.gateway.api.endpoint

Methods in org.apache.flink.table.gateway.api.endpoint that return SqlGatewayService

Modifier and Type	Method and Description
SqlGatewayService	SqlGatewayEndpointFactoryUtils.DefaultEndpointFactoryContext.getSqlGatewayService()
SqlGatewayService	SqlGatewayEndpointFactory.Context.getSqlGatewayService() Get the service to execute the request.

Methods in org.apache.flink.table.gateway.api.endpoint with parameters of type SqlGatewayService

Modifier and Type	Method and Description
static List<SqlGatewayEndpoint>	SqlGatewayEndpointFactoryUtils.createSqlGatewayEndpoint(SqlGatewayService service, Configuration configuration) Attempts to discover the appropriate endpoint factory and creates the instance of the endpoints.

Constructors in org.apache.flink.table.gateway.api.endpoint with parameters of type SqlGatewayService

Constructor and Description
DefaultEndpointFactoryContext(SqlGatewayService service, Configuration flinkConfiguration, Map<String,String> endpointConfig)

Uses of SqlGatewayService in org.apache.flink.table.gateway.rest

Fields in org.apache.flink.table.gateway.rest declared as SqlGatewayService

Modifier and Type	Field and Description
SqlGatewayService	SqlGatewayRestEndpoint.service

Constructors in org.apache.flink.table.gateway.rest with parameters of type SqlGatewayService

Constructor and Description
SqlGatewayRestEndpoint(Configuration configuration, SqlGatewayService sqlGatewayService)

Uses of SqlGatewayService in org.apache.flink.table.gateway.rest.handler

Fields in org.apache.flink.table.gateway.rest.handler declared as SqlGatewayService

Modifier and Type	Field and Description
protected SqlGatewayService	AbstractSqlGatewayRestHandler.service

Constructors in org.apache.flink.table.gateway.rest.handler with parameters of type SqlGatewayService

Constructor and Description
AbstractSqlGatewayRestHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<R,P,M> messageHeaders)

Uses of SqlGatewayService in org.apache.flink.table.gateway.rest.handler.materializedtable

Constructors in org.apache.flink.table.gateway.rest.handler.materializedtable with parameters of type SqlGatewayService

Constructor and Description
RefreshMaterializedTableHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<RefreshMaterializedTableRequestBody,RefreshMaterializedTableResponseBody,RefreshMaterializedTableParameters> messageHeaders)

Uses of SqlGatewayService in org.apache.flink.table.gateway.rest.handler.materializedtable.scheduler

Constructors in org.apache.flink.table.gateway.rest.handler.materializedtable.scheduler with parameters of type SqlGatewayService

Constructor and Description
CreateEmbeddedSchedulerWorkflowHandler(SqlGatewayService service, EmbeddedQuartzScheduler quartzScheduler, Map<String,String> responseHeaders, MessageHeaders<CreateEmbeddedSchedulerWorkflowRequestBody,CreateEmbeddedSchedulerWorkflowResponseBody,EmptyMessageParameters> messageHeaders)
DeleteEmbeddedSchedulerWorkflowHandler(SqlGatewayService service, EmbeddedQuartzScheduler quartzScheduler, Map<String,String> responseHeaders, MessageHeaders<EmbeddedSchedulerWorkflowRequestBody,EmptyResponseBody,EmptyMessageParameters> messageHeaders)
ResumeEmbeddedSchedulerWorkflowHandler(SqlGatewayService service, EmbeddedQuartzScheduler quartzScheduler, Map<String,String> responseHeaders, MessageHeaders<ResumeEmbeddedSchedulerWorkflowRequestBody,EmptyResponseBody,EmptyMessageParameters> messageHeaders)
SuspendEmbeddedSchedulerWorkflowHandler(SqlGatewayService service, EmbeddedQuartzScheduler quartzScheduler, Map<String,String> responseHeaders, MessageHeaders<EmbeddedSchedulerWorkflowRequestBody,EmptyResponseBody,EmptyMessageParameters> messageHeaders)

Uses of SqlGatewayService in org.apache.flink.table.gateway.rest.handler.operation

Constructors in org.apache.flink.table.gateway.rest.handler.operation with parameters of type SqlGatewayService

Constructor and Description
AbstractOperationHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,OperationStatusResponseBody,OperationMessageParameters> messageHeaders)
CancelOperationHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,OperationStatusResponseBody,OperationMessageParameters> messageHeaders)
CloseOperationHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,OperationStatusResponseBody,OperationMessageParameters> messageHeaders)
GetOperationStatusHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,OperationStatusResponseBody,OperationMessageParameters> messageHeaders)

Uses of SqlGatewayService in org.apache.flink.table.gateway.rest.handler.session

Constructors in org.apache.flink.table.gateway.rest.handler.session with parameters of type SqlGatewayService

Constructor and Description
CloseSessionHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,CloseSessionResponseBody,SessionMessageParameters> messageHeaders)
ConfigureSessionHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<ConfigureSessionRequestBody,EmptyResponseBody,SessionMessageParameters> messageHeaders)
GetSessionConfigHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,GetSessionConfigResponseBody,SessionMessageParameters> messageHeaders)
OpenSessionHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<OpenSessionRequestBody,OpenSessionResponseBody,EmptyMessageParameters> messageHeaders)
TriggerSessionHeartbeatHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,EmptyResponseBody,SessionMessageParameters> messageHeaders)

Uses of SqlGatewayService in org.apache.flink.table.gateway.rest.handler.statement

Constructors in org.apache.flink.table.gateway.rest.handler.statement with parameters of type SqlGatewayService

Constructor and Description
CompleteStatementHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<CompleteStatementRequestBody,CompleteStatementResponseBody,SessionMessageParameters> messageHeaders)
ExecuteStatementHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<ExecuteStatementRequestBody,ExecuteStatementResponseBody,SessionMessageParameters> messageHeaders)
FetchResultsHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,FetchResultsResponseBody,FetchResultsMessageParameters> messageHeaders)

Uses of SqlGatewayService in org.apache.flink.table.gateway.rest.handler.util

Constructors in org.apache.flink.table.gateway.rest.handler.util with parameters of type SqlGatewayService

Constructor and Description
GetApiVersionHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,GetApiVersionResponseBody,EmptyMessageParameters> messageHeaders)
GetApiVersionHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,GetApiVersionResponseBody,EmptyMessageParameters> messageHeaders, List<SqlGatewayRestAPIVersion> stableVersions)
GetInfoHandler(SqlGatewayService service, Map<String,String> responseHeaders, MessageHeaders<EmptyRequestBody,GetInfoResponseBody,EmptyMessageParameters> messageHeaders)

Uses of SqlGatewayService in org.apache.flink.table.gateway.service

Classes in org.apache.flink.table.gateway.service that implement SqlGatewayService

Modifier and Type	Class and Description
class	SqlGatewayServiceImpl The implementation of the SqlGatewayService interface.