This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from db3c341 [FLINK-17074] Deprecate scala Datastream.partitionCustom
methods that do not use KeySelector
add ddf6a0d [FLINK-17210][sql-parser][hive] Implement database DDLs for
Hive dialect
No new revisions were added by this update.
Summary of changes:
.../flink/table/catalog/hive/HiveCatalog.java | 76 +--
.../table/catalog/hive/HiveCatalogConfig.java | 3 -
.../flink/table/catalog/hive/HiveDatabaseUtil.java | 108 ++++
.../flink/connectors/hive/HiveDialectTest.java | 115 +++++
.../catalog/hive/HiveCatalogHiveMetadataTest.java | 21 +
flink-table/flink-sql-parser-hive/pom.xml | 217 ++++++++
.../src/main/codegen/config.fmpp | 0
.../src/main/codegen/data/Parser.tdd | 547 +++++++++++++++++++++
.../main/codegen/includes/compoundIdentifier.ftl | 0
.../src/main/codegen/includes/parserImpls.ftl | 221 +++++++++
.../flink/sql/parser/hive/ddl/HiveDDLUtils.java | 94 ++++
.../sql/parser/hive/ddl/SqlAlterHiveDatabase.java | 60 +++
.../hive/ddl/SqlAlterHiveDatabaseLocation.java | 59 +++
.../parser/hive/ddl/SqlAlterHiveDatabaseOwner.java | 75 +++
.../parser/hive/ddl/SqlAlterHiveDatabaseProps.java | 56 +++
.../sql/parser/hive/ddl/SqlCreateHiveDatabase.java | 91 ++++
.../apache/flink/sql/parser/hive/package-info.java | 39 ++
.../parser/hive/FlinkHiveSqlParserImplTest.java | 101 ++++
.../flink/sql/parser/ddl/SqlAlterDatabase.java | 2 +-
.../flink/sql/parser/ddl/SqlCreateDatabase.java | 2 +-
.../flink/table/catalog/CatalogTestBase.java | 2 +
flink-table/flink-table-planner-blink/pom.xml | 13 +
.../delegation/FlinkSqlParserFactories.java | 43 ++
.../table/planner/delegation/PlannerContext.java | 26 +-
flink-table/flink-table-uber-blink/pom.xml | 5 +
flink-table/pom.xml | 1 +
26 files changed, 1925 insertions(+), 52 deletions(-)
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveDatabaseUtil.java
create mode 100644
flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveDialectTest.java
create mode 100644 flink-table/flink-sql-parser-hive/pom.xml
copy flink-table/{flink-sql-parser =>
flink-sql-parser-hive}/src/main/codegen/config.fmpp (100%)
create mode 100644
flink-table/flink-sql-parser-hive/src/main/codegen/data/Parser.tdd
copy flink-table/{flink-sql-parser =>
flink-sql-parser-hive}/src/main/codegen/includes/compoundIdentifier.ftl (100%)
create mode 100644
flink-table/flink-sql-parser-hive/src/main/codegen/includes/parserImpls.ftl
create mode 100644
flink-table/flink-sql-parser-hive/src/main/java/org/apache/flink/sql/parser/hive/ddl/HiveDDLUtils.java
create mode 100644
flink-table/flink-sql-parser-hive/src/main/java/org/apache/flink/sql/parser/hive/ddl/SqlAlterHiveDatabase.java
create mode 100644
flink-table/flink-sql-parser-hive/src/main/java/org/apache/flink/sql/parser/hive/ddl/SqlAlterHiveDatabaseLocation.java
create mode 100644
flink-table/flink-sql-parser-hive/src/main/java/org/apache/flink/sql/parser/hive/ddl/SqlAlterHiveDatabaseOwner.java
create mode 100644
flink-table/flink-sql-parser-hive/src/main/java/org/apache/flink/sql/parser/hive/ddl/SqlAlterHiveDatabaseProps.java
create mode 100644
flink-table/flink-sql-parser-hive/src/main/java/org/apache/flink/sql/parser/hive/ddl/SqlCreateHiveDatabase.java
create mode 100644
flink-table/flink-sql-parser-hive/src/main/java/org/apache/flink/sql/parser/hive/package-info.java
create mode 100644
flink-table/flink-sql-parser-hive/src/test/java/org/apache/flink/sql/parser/hive/FlinkHiveSqlParserImplTest.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/delegation/FlinkSqlParserFactories.java
