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 8017a417515 [FLINK-27618][sql] Flink SQL supports CUME_DIST function
(#19727)
add d067629d4d2 [FLINK-28150][sql-gateway][hive] Introduce the hiveserver2
endpoint and factory
No new revisions were added by this update.
Summary of changes:
.../architecture/common/JavaFieldPredicates.java | 13 +-
.../flink-architecture-tests-production/pom.xml | 10 +
flink-architecture-tests/pom.xml | 14 +
flink-connectors/flink-connector-hive/pom.xml | 50 +++
.../flink/table/catalog/hive/HiveCatalog.java | 11 +-
.../table/endpoint/hive/HiveServer2Endpoint.java | 495 +++++++++++++++++++++
.../hive/HiveServer2EndpointConfigOptions.java | 119 +++++
.../endpoint/hive/HiveServer2EndpointFactory.java | 130 ++++++
.../endpoint/hive/HiveServer2EndpointVersion.java | 84 ++++
.../endpoint/hive/util/HiveJdbcParameterUtils.java | 100 +++++
.../hive/util/ThriftObjectConversions.java | 123 +++++
.../org.apache.flink.table.factories.Factory | 1 +
.../flink/table/catalog/hive/HiveTestUtils.java | 11 +
.../hive/HiveServer2EndpointFactoryTest.java | 182 ++++++++
.../endpoint/hive/HiveServer2EndpointITCase.java | 134 ++++++
.../hive/util/HiveServer2EndpointExtension.java | 98 ++++
.../hive/util/ThriftObjectConversionsTest.java | 37 ++
.../main/java/org/apache/flink/util/FileLock.java | 2 +-
flink-table/flink-sql-client/pom.xml | 7 +
.../flink/table/gateway/api/HandleIdentifier.java | 4 +
.../api/endpoint/SqlGatewayEndpointFactory.java | 1 +
.../endpoint/SqlGatewayEndpointFactoryUtils.java | 13 +-
.../flink/table/gateway/api/results/ResultSet.java | 1 +
.../gateway/api/session/SessionEnvironment.java | 87 +++-
.../table/gateway/api}/utils/ThreadUtils.java | 5 +-
.../api/session/SessionEnvironmentTest.java | 11 +-
flink-table/flink-sql-gateway/pom.xml | 58 ++-
.../gateway/service/context/SessionContext.java | 58 ++-
.../service/operation/OperationExecutor.java | 11 +-
.../gateway/service/session/SessionManager.java | 10 +-
.../gateway/service/SqlGatewayServiceITCase.java | 31 ++
.../service/context/SessionContextTest.java | 2 +-
flink-table/flink-table-api-java-uber/pom.xml | 6 +
.../apache/flink/table/factories/FactoryUtil.java | 7 +
34 files changed, 1852 insertions(+), 74 deletions(-)
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/endpoint/hive/HiveServer2Endpoint.java
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/endpoint/hive/HiveServer2EndpointConfigOptions.java
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/endpoint/hive/HiveServer2EndpointFactory.java
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/endpoint/hive/HiveServer2EndpointVersion.java
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/endpoint/hive/util/HiveJdbcParameterUtils.java
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/endpoint/hive/util/ThriftObjectConversions.java
create mode 100644
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/endpoint/hive/HiveServer2EndpointFactoryTest.java
create mode 100644
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/endpoint/hive/HiveServer2EndpointITCase.java
create mode 100644
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/endpoint/hive/util/HiveServer2EndpointExtension.java
create mode 100644
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/endpoint/hive/util/ThriftObjectConversionsTest.java
rename
flink-table/{flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service
=>
flink-sql-gateway-api/src/main/java/org/apache/flink/table/gateway/api}/utils/ThreadUtils.java
(94%)
