This is an automated email from the ASF dual-hosted git repository.
shengkai pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from db4f7781173 [FLINK-28634][json] Deprecate JsonNodeDeserializationSchema
new 27cecdebccc [FLINK-28152][sql-gateway][hive] Introduce option
"thrift.host" for HiveServer2 Endpoint and improve codes
new 1fb5875ae6e [FLINK-28152][sql-gateway] Simplify SessionHandle and
OperationHandle
new f477a43ff23 [FLINK-28152][sql-gateway][hive] Support
GetOperationStatus and GetResultSetMetadata for HiveServer2Endpoint
new 6a95672db9c [FLINK-28152][sql-gateway][hive] Allow executing statement
and fetching results for the HiveServer2Endpoint
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
flink-connectors/flink-connector-hive/pom.xml | 7 +
.../table/endpoint/hive/HiveServer2Endpoint.java | 204 +++++-
.../hive/HiveServer2EndpointConfigOptions.java | 11 +-
.../endpoint/hive/HiveServer2EndpointFactory.java | 23 +-
.../hive/util/ThriftObjectConversions.java | 523 +++++++++++++-
.../hive/HiveServer2EndpointFactoryTest.java | 93 +--
.../endpoint/hive/HiveServer2EndpointITCase.java | 23 +-
.../hive/HiveServer2EndpointStatementITCase.java | 180 +++++
.../hive/util/HiveServer2EndpointExtension.java | 14 +-
.../hive/util/ThriftObjectConversionsTest.java | 318 +++++++++
.../src/test/resources/endpoint/hive_catalog.q | 121 ++++
.../src/test/resources/endpoint/hive_module.q | 240 +++++++
.../src/test/resources/endpoint/select.q | 130 ++++
.../flink/table/gateway/api/HandleIdentifier.java | 67 --
.../flink/table/gateway/api/SqlGatewayService.java | 43 ++
.../gateway/api/operation/OperationHandle.java | 9 +-
.../gateway/api/results/FetchOrientation.java} | 28 +-
.../table/gateway/api/results/OperationInfo.java | 26 +-
.../gateway/api/session/SessionEnvironment.java | 2 +-
.../table/gateway/api/session/SessionHandle.java | 9 +-
.../gateway/api/utils/MockedSqlGatewayService.java | 25 +
.../gateway/service/SqlGatewayServiceImpl.java | 44 ++
.../gateway/service/context/SessionContext.java | 12 +-
.../service/operation/OperationManager.java | 46 +-
.../gateway/service/result/ResultFetcher.java | 38 +-
.../table/gateway/service/result/ResultStore.java | 24 +-
.../table/gateway/service/session/Session.java | 5 +
.../gateway/service/session/SessionManager.java | 2 +-
.../gateway/AbstractSqlGatewayStatementITCase.java | 307 +++++++++
.../gateway/service/SqlGatewayServiceITCase.java | 10 +-
.../service/SqlGatewayServiceStatementITCase.java | 265 ++------
.../gateway/service/result/ResultFetcherTest.java | 131 +++-
.../{service => }/utils/SqlScriptReader.java | 2 +-
.../{service => }/utils/TestSqlStatement.java | 2 +-
.../src/test/resources/sql/catalog_database.q | 756 +++++++++++++++++++++
.../table/api/internal/StaticResultProvider.java | 4 +-
36 files changed, 3295 insertions(+), 449 deletions(-)
create mode 100644
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/endpoint/hive/HiveServer2EndpointStatementITCase.java
create mode 100644
flink-connectors/flink-connector-hive/src/test/resources/endpoint/hive_catalog.q
create mode 100644
flink-connectors/flink-connector-hive/src/test/resources/endpoint/hive_module.q
create mode 100644
flink-connectors/flink-connector-hive/src/test/resources/endpoint/select.q
delete mode 100644
flink-table/flink-sql-gateway-api/src/main/java/org/apache/flink/table/gateway/api/HandleIdentifier.java
copy
flink-table/{flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/utils/TestSqlStatement.java
=>
flink-sql-gateway-api/src/main/java/org/apache/flink/table/gateway/api/results/FetchOrientation.java}
(63%)
create mode 100644
flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/AbstractSqlGatewayStatementITCase.java
rename
flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/{service
=> }/utils/SqlScriptReader.java (98%)
rename
flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/{service
=> }/utils/TestSqlStatement.java (95%)
create mode 100644
flink-table/flink-sql-gateway/src/test/resources/sql/catalog_database.q
