Uses of Class
org.apache.flink.table.gateway.rest.util.SqlGatewayRestAPIVersion
-
-
Uses of SqlGatewayRestAPIVersion in org.apache.flink.table.gateway.rest.handler
Methods in org.apache.flink.table.gateway.rest.handler with parameters of type SqlGatewayRestAPIVersion Modifier and Type Method Description protected abstract CompletableFuture<P>AbstractSqlGatewayRestHandler. handleRequest(SqlGatewayRestAPIVersion version, org.apache.flink.runtime.rest.handler.HandlerRequest<R> request)This method is called for every incoming request and returns aCompletableFuturecontaining a the response. -
Uses of SqlGatewayRestAPIVersion in org.apache.flink.table.gateway.rest.handler.application
Methods in org.apache.flink.table.gateway.rest.handler.application with parameters of type SqlGatewayRestAPIVersion Modifier and Type Method Description protected CompletableFuture<DeployScriptResponseBody>DeployScriptHandler. handleRequest(SqlGatewayRestAPIVersion version, org.apache.flink.runtime.rest.handler.HandlerRequest<DeployScriptRequestBody> request) -
Uses of SqlGatewayRestAPIVersion in org.apache.flink.table.gateway.rest.handler.materializedtable
Methods in org.apache.flink.table.gateway.rest.handler.materializedtable with parameters of type SqlGatewayRestAPIVersion Modifier and Type Method Description protected CompletableFuture<RefreshMaterializedTableResponseBody>RefreshMaterializedTableHandler. handleRequest(SqlGatewayRestAPIVersion version, org.apache.flink.runtime.rest.handler.HandlerRequest<RefreshMaterializedTableRequestBody> request) -
Uses of SqlGatewayRestAPIVersion in org.apache.flink.table.gateway.rest.handler.materializedtable.scheduler
Methods in org.apache.flink.table.gateway.rest.handler.materializedtable.scheduler with parameters of type SqlGatewayRestAPIVersion Modifier and Type Method Description protected CompletableFuture<CreateEmbeddedSchedulerWorkflowResponseBody>CreateEmbeddedSchedulerWorkflowHandler. handleRequest(SqlGatewayRestAPIVersion version, org.apache.flink.runtime.rest.handler.HandlerRequest<CreateEmbeddedSchedulerWorkflowRequestBody> request)protected CompletableFuture<org.apache.flink.runtime.rest.messages.EmptyResponseBody>DeleteEmbeddedSchedulerWorkflowHandler. handleRequest(SqlGatewayRestAPIVersion version, org.apache.flink.runtime.rest.handler.HandlerRequest<EmbeddedSchedulerWorkflowRequestBody> request)protected CompletableFuture<org.apache.flink.runtime.rest.messages.EmptyResponseBody>ResumeEmbeddedSchedulerWorkflowHandler. handleRequest(SqlGatewayRestAPIVersion version, org.apache.flink.runtime.rest.handler.HandlerRequest<ResumeEmbeddedSchedulerWorkflowRequestBody> request)protected CompletableFuture<org.apache.flink.runtime.rest.messages.EmptyResponseBody>SuspendEmbeddedSchedulerWorkflowHandler. handleRequest(SqlGatewayRestAPIVersion version, org.apache.flink.runtime.rest.handler.HandlerRequest<EmbeddedSchedulerWorkflowRequestBody> request) -
Uses of SqlGatewayRestAPIVersion in org.apache.flink.table.gateway.rest.handler.operation
Methods in org.apache.flink.table.gateway.rest.handler.operation with parameters of type SqlGatewayRestAPIVersion Modifier and Type Method Description protected CompletableFuture<OperationStatusResponseBody>AbstractOperationHandler. handleRequest(SqlGatewayRestAPIVersion version, org.apache.flink.runtime.rest.handler.HandlerRequest<org.apache.flink.runtime.rest.messages.EmptyRequestBody> request) -
Uses of SqlGatewayRestAPIVersion in org.apache.flink.table.gateway.rest.handler.session
Methods in org.apache.flink.table.gateway.rest.handler.session with parameters of type SqlGatewayRestAPIVersion Modifier and Type Method Description protected CompletableFuture<CloseSessionResponseBody>CloseSessionHandler. handleRequest(SqlGatewayRestAPIVersion version, org.apache.flink.runtime.rest.handler.HandlerRequest<org.apache.flink.runtime.rest.messages.EmptyRequestBody> request)protected CompletableFuture<org.apache.flink.runtime.rest.messages.EmptyResponseBody>ConfigureSessionHandler. handleRequest(SqlGatewayRestAPIVersion version, org.apache.flink.runtime.rest.handler.HandlerRequest<ConfigureSessionRequestBody> request)protected CompletableFuture<GetSessionConfigResponseBody>GetSessionConfigHandler. handleRequest(SqlGatewayRestAPIVersion version, org.apache.flink.runtime.rest.handler.HandlerRequest<org.apache.flink.runtime.rest.messages.EmptyRequestBody> request)protected CompletableFuture<OpenSessionResponseBody>OpenSessionHandler. handleRequest(SqlGatewayRestAPIVersion version, org.apache.flink.runtime.rest.handler.HandlerRequest<OpenSessionRequestBody> request)protected CompletableFuture<org.apache.flink.runtime.rest.messages.EmptyResponseBody>TriggerSessionHeartbeatHandler. handleRequest(SqlGatewayRestAPIVersion version, org.apache.flink.runtime.rest.handler.HandlerRequest<org.apache.flink.runtime.rest.messages.EmptyRequestBody> request) -
Uses of SqlGatewayRestAPIVersion in org.apache.flink.table.gateway.rest.handler.statement
Methods in org.apache.flink.table.gateway.rest.handler.statement with parameters of type SqlGatewayRestAPIVersion Modifier and Type Method Description protected CompletableFuture<CompleteStatementResponseBody>CompleteStatementHandler. handleRequest(SqlGatewayRestAPIVersion version, org.apache.flink.runtime.rest.handler.HandlerRequest<CompleteStatementRequestBody> request)protected CompletableFuture<ExecuteStatementResponseBody>ExecuteStatementHandler. handleRequest(SqlGatewayRestAPIVersion version, org.apache.flink.runtime.rest.handler.HandlerRequest<ExecuteStatementRequestBody> request)protected CompletableFuture<FetchResultsResponseBody>FetchResultsHandler. handleRequest(SqlGatewayRestAPIVersion version, org.apache.flink.runtime.rest.handler.HandlerRequest<org.apache.flink.runtime.rest.messages.EmptyRequestBody> request) -
Uses of SqlGatewayRestAPIVersion in org.apache.flink.table.gateway.rest.handler.util
Methods in org.apache.flink.table.gateway.rest.handler.util with parameters of type SqlGatewayRestAPIVersion Modifier and Type Method Description protected CompletableFuture<GetApiVersionResponseBody>GetApiVersionHandler. handleRequest(SqlGatewayRestAPIVersion version, org.apache.flink.runtime.rest.handler.HandlerRequest<org.apache.flink.runtime.rest.messages.EmptyRequestBody> request)protected CompletableFuture<GetInfoResponseBody>GetInfoHandler. handleRequest(SqlGatewayRestAPIVersion version, org.apache.flink.runtime.rest.handler.HandlerRequest<org.apache.flink.runtime.rest.messages.EmptyRequestBody> request)Constructor parameters in org.apache.flink.table.gateway.rest.handler.util with type arguments of type SqlGatewayRestAPIVersion Constructor Description GetApiVersionHandler(org.apache.flink.table.gateway.api.SqlGatewayService service, Map<String,String> responseHeaders, org.apache.flink.runtime.rest.messages.MessageHeaders<org.apache.flink.runtime.rest.messages.EmptyRequestBody,GetApiVersionResponseBody,org.apache.flink.runtime.rest.messages.EmptyMessageParameters> messageHeaders, List<SqlGatewayRestAPIVersion> stableVersions) -
Uses of SqlGatewayRestAPIVersion in org.apache.flink.table.gateway.rest.header.statement
Methods in org.apache.flink.table.gateway.rest.header.statement with parameters of type SqlGatewayRestAPIVersion Modifier and Type Method Description static StringFetchResultsHeaders. buildNextUri(SqlGatewayRestAPIVersion version, String sessionId, String operationId, Long nextToken, RowFormat rowFormat) -
Uses of SqlGatewayRestAPIVersion in org.apache.flink.table.gateway.rest.message.statement
Constructors in org.apache.flink.table.gateway.rest.message.statement with parameters of type SqlGatewayRestAPIVersion Constructor Description FetchResultsMessageParameters(SqlGatewayRestAPIVersion version) -
Uses of SqlGatewayRestAPIVersion in org.apache.flink.table.gateway.rest.util
Methods in org.apache.flink.table.gateway.rest.util that return SqlGatewayRestAPIVersion Modifier and Type Method Description static SqlGatewayRestAPIVersionSqlGatewayRestAPIVersion. fromURIToVersion(String uri)Convert uri to SqlGatewayRestAPIVersion.static SqlGatewayRestAPIVersionSqlGatewayRestAPIVersion. getDefaultVersion()Returns the default version.static SqlGatewayRestAPIVersionSqlGatewayRestAPIVersion. valueOf(String name)Returns the enum constant of this type with the specified name.static SqlGatewayRestAPIVersion[]SqlGatewayRestAPIVersion. values()Returns an array containing the constants of this enum type, in the order they are declared.Methods in org.apache.flink.table.gateway.rest.util that return types with arguments of type SqlGatewayRestAPIVersion Modifier and Type Method Description static List<SqlGatewayRestAPIVersion>SqlGatewayRestAPIVersion. getHigherVersions(SqlGatewayRestAPIVersion version)Get higher versions comparing to the input version.static List<SqlGatewayRestAPIVersion>SqlGatewayRestAPIVersion. getStableVersions()Returns the supported stable versions.Methods in org.apache.flink.table.gateway.rest.util with parameters of type SqlGatewayRestAPIVersion Modifier and Type Method Description static List<SqlGatewayRestAPIVersion>SqlGatewayRestAPIVersion. getHigherVersions(SqlGatewayRestAPIVersion version)Get higher versions comparing to the input version.
-