This is an automated email from the ASF dual-hosted git repository.
xtsong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from def2f543809 [FLINK-28631][sql-gateway][hive] Support to GetFunctions
in the HiveServer2Endpoint
add fcde111410d [hotfix][sql-gateway] Use camelCase for REST
request/response body fields in session related APIs.
add 91eccea38c8 [FLINK-28162][sql-gateway]Introduce the operation related
API for REST endpoint
add 41bde65874c [FLINK-28164][sql-gateway]Introduce utilities API for REST
endpoint
add 47970b0435a [FLINK-28163][sql-gateway]Introduce the statement related
API for REST endpoint
No new revisions were added by this update.
Summary of changes:
.../flink/architecture/rules/TableApiRules.java | 2 +
.../flink/runtime/rest/HttpMethodWrapper.java | 3 +-
.../flink/runtime/rest/RestServerEndpoint.java | 3 +
flink-table/flink-sql-gateway-api/pom.xml | 12 +-
.../table/gateway/api/results/ColumnInfo.java | 98 ++++++++
.../api/results/JsonResultSetDeserializer.java | 122 +++++++++
.../api/results/JsonResultSetSerializer.java | 118 +++++++++
.../flink/table/gateway/api/results/ResultSet.java | 14 +-
.../table/gateway/api/results/RowDataInfo.java | 59 +++++
.../api/results/JsonResultSetSerDeTest.java | 276 +++++++++++++++++++++
.../table/gateway/rest/SqlGatewayRestEndpoint.java | 69 ++++++
.../operation/AbstractOperationHandler.java | 82 ++++++
.../handler/operation/CancelOperationHandler.java | 49 ++++
.../handler/operation/CloseOperationHandler.java | 55 ++++
.../operation/GetOperationStatusHandler.java | 42 ++++
.../handler/statement/ExecuteStatementHandler.java | 77 ++++++
.../handler/statement/FetchResultsHandler.java | 91 +++++++
.../rest/handler/util/GetApiVersionHandler.java | 62 +++++
.../gateway/rest/handler/util/GetInfoHandler.java | 59 +++++
.../header/operation/AbstactOperationHeaders.java | 52 ++++
.../header/operation/CancelOperationHeaders.java | 55 ++++
.../header/operation/CloseOperationHeaders.java | 55 ++++
.../operation/GetOperationStatusHeaders.java | 55 ++++
.../header/statement/ExecuteStatementHeaders.java | 80 ++++++
.../rest/header/statement/FetchResultsHeaders.java | 100 ++++++++
.../rest/header/util/GetApiVersionHeaders.java | 77 ++++++
.../gateway/rest/header/util/GetInfoHeaders.java | 77 ++++++
.../operation/OperationHandleIdPathParameter.java | 49 ++++
.../operation/OperationMessageParameters.java | 60 +++++
.../OperationStatusResponseBody.java} | 20 +-
.../message/session/OpenSessionRequestBody.java | 2 +-
.../message/session/OpenSessionResponseBody.java | 2 +-
.../statement/ExecuteStatementRequestBody.java | 72 ++++++
.../ExecuteStatementResponseBody.java} | 21 +-
.../statement/FetchResultsResponseBody.java | 66 +++++
.../statement/FetchResultsTokenParameters.java | 68 +++++
.../statement/FetchResultsTokenPathParameter.java | 35 +--
.../GetApiVersionResponseBody.java} | 22 +-
.../GetInfoResponseBody.java} | 31 ++-
.../table/gateway/rest/OperationCaseITTest.java | 170 +++++++++++++
.../table/gateway/rest/StatementCaseITTest.java | 273 ++++++++++++++++++++
.../flink/table/gateway/rest/UtilCaseITTest.java | 74 ++++++
42 files changed, 2749 insertions(+), 60 deletions(-)
create mode 100644
flink-table/flink-sql-gateway-api/src/main/java/org/apache/flink/table/gateway/api/results/ColumnInfo.java
create mode 100644
flink-table/flink-sql-gateway-api/src/main/java/org/apache/flink/table/gateway/api/results/JsonResultSetDeserializer.java
create mode 100644
flink-table/flink-sql-gateway-api/src/main/java/org/apache/flink/table/gateway/api/results/JsonResultSetSerializer.java
create mode 100644
flink-table/flink-sql-gateway-api/src/main/java/org/apache/flink/table/gateway/api/results/RowDataInfo.java
create mode 100644
flink-table/flink-sql-gateway-api/src/test/java/org/apache/flink/table/gateway/api/results/JsonResultSetSerDeTest.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/handler/operation/AbstractOperationHandler.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/handler/operation/CancelOperationHandler.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/handler/operation/CloseOperationHandler.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/handler/operation/GetOperationStatusHandler.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/handler/statement/ExecuteStatementHandler.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/handler/statement/FetchResultsHandler.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/handler/util/GetApiVersionHandler.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/handler/util/GetInfoHandler.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/header/operation/AbstactOperationHeaders.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/header/operation/CancelOperationHeaders.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/header/operation/CloseOperationHeaders.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/header/operation/GetOperationStatusHeaders.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/header/statement/ExecuteStatementHeaders.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/header/statement/FetchResultsHeaders.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/header/util/GetApiVersionHeaders.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/header/util/GetInfoHeaders.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/operation/OperationHandleIdPathParameter.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/operation/OperationMessageParameters.java
copy
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/{session/OpenSessionResponseBody.java
=> operation/OperationStatusResponseBody.java} (67%)
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/statement/ExecuteStatementRequestBody.java
copy
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/{session/OpenSessionResponseBody.java
=> statement/ExecuteStatementResponseBody.java} (65%)
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/statement/FetchResultsResponseBody.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/statement/FetchResultsTokenParameters.java
copy
flink-runtime/src/main/java/org/apache/flink/runtime/rest/HttpMethodWrapper.java
=>
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/statement/FetchResultsTokenPathParameter.java
(53%)
copy
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/{session/OpenSessionResponseBody.java
=> util/GetApiVersionResponseBody.java} (67%)
copy
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/{session/OpenSessionResponseBody.java
=> util/GetInfoResponseBody.java} (55%)
create mode 100644
flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/rest/OperationCaseITTest.java
create mode 100644
flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/rest/StatementCaseITTest.java
create mode 100644
flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/rest/UtilCaseITTest.java
