This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from e2b7256 [FLINK-21704][table-planner-blink] Support json
serialization/deserialization for ChangelogSource
add 7bf296b [FLINK-21727][table-planner-blink] Add getter for
catalogManager in ParserImpl
add 95d6278 [FLINK-21727][table][hive] Support DDL in HiveParser
No new revisions were added by this update.
Summary of changes:
.../catalog/hive/util/HiveReflectionUtils.java | 23 +
.../delegation/hive/DDLOperationConverter.java | 818 +++++++++
.../table/planner/delegation/hive/HiveParser.java | 281 ++-
.../hive/HiveParserAuthorizationParseUtils.java | 55 +
.../delegation/hive/HiveParserConstants.java | 30 +
.../delegation/hive/HiveParserQueryState.java | 90 +
.../planner/delegation/hive/HiveParserUtils.java | 45 +
.../delegation/hive/desc/CreateTableASDesc.java | 45 +
.../delegation/hive/desc/DropPartitionDesc.java | 58 +
.../hive/desc/HiveParserAlterDatabaseDesc.java | 122 ++
.../hive/desc/HiveParserAlterTableDesc.java | 375 ++++
.../hive/desc/HiveParserCreateTableDesc.java | 246 +++
.../hive/desc/HiveParserCreateViewDesc.java | 112 ++
.../hive/desc/HiveParserDropDatabaseDesc.java | 48 +
.../hive/desc/HiveParserDropFunctionDesc.java | 45 +
.../hive/desc/HiveParserDropTableDesc.java | 55 +
.../hive/desc/HiveParserShowTablesDesc.java | 48 +
.../hive/parse/HiveParserBaseSemanticAnalyzer.java | 1121 ++++++++++++
.../hive/parse/HiveParserDDLSemanticAnalyzer.java | 1820 ++++++++++++++++++++
.../hive/parse/HiveParserStorageFormat.java | 179 ++
.../flink/connectors/hive/HiveDialectITCase.java | 33 +-
.../sql/parser/hive/ddl/SqlCreateHiveTable.java | 10 +-
.../table/api/internal/TableEnvironmentImpl.java | 3 +-
.../flink/table/catalog/FunctionCatalog.java | 6 +-
.../ddl/CreateTempSystemFunctionOperation.java | 31 +-
.../flink/table/planner/delegation/ParserImpl.java | 4 +
.../planner/utils/OperationConverterUtils.java | 38 +-
.../flink/table/api/internal/TableEnvImpl.scala | 3 +-
28 files changed, 5702 insertions(+), 42 deletions(-)
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/DDLOperationConverter.java
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParserAuthorizationParseUtils.java
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParserConstants.java
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParserQueryState.java
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParserUtils.java
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/desc/CreateTableASDesc.java
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/desc/DropPartitionDesc.java
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/desc/HiveParserAlterDatabaseDesc.java
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/desc/HiveParserAlterTableDesc.java
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/desc/HiveParserCreateTableDesc.java
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/desc/HiveParserCreateViewDesc.java
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/desc/HiveParserDropDatabaseDesc.java
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/desc/HiveParserDropFunctionDesc.java
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/desc/HiveParserDropTableDesc.java
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/desc/HiveParserShowTablesDesc.java
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/parse/HiveParserBaseSemanticAnalyzer.java
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/parse/HiveParserDDLSemanticAnalyzer.java
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/parse/HiveParserStorageFormat.java
