[flink] branch master updated (a38d9f6 -> 28ab459)

[ja...@apache.org]

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 a38d9f6  [FLINK-16989][table-planner-blink] Support ScanTableSource in blink planner
     add 49956b5  [FLINK-17030][sql-parser] Add primary key syntax for CREATE TABLE
     add 9add89e  [FLINK-17030][sql-parser] Add primary key syntax for ALTER TABLE
     add 3765fe9  [FLINK-17030][table-planner-blink] Add primary key syntax for CREATE TABLE
     add 28ab459  [FLINK-17030][table-planner-blink] Add primary key syntax for ALTER TABLE

No new revisions were added by this update.

Summary of changes:
 .../src/main/codegen/data/Parser.tdd               |  10 +-
 .../src/main/codegen/includes/parserImpls.ftl      | 146 +++++++++++---
 ...Rename.java => SqlAlterTableAddConstraint.java} |  43 +++--
 ...ename.java => SqlAlterTableDropConstraint.java} |  39 ++--
 .../flink/sql/parser/ddl/SqlCreateTable.java       | 147 +++++++++-----
 .../flink/sql/parser/ddl/SqlTableColumn.java       |  16 +-
 .../constraint/SqlConstraintEnforcement.java}      |  26 ++-
 .../parser/ddl/constraint/SqlTableConstraint.java  | 169 ++++++++++++++++
 .../constraint/SqlUniqueSpec.java}                 |  26 ++-
 .../flink/sql/parser/FlinkSqlParserImplTest.java   | 152 ++++++++++++---
 .../table/api/internal/TableEnvironmentImpl.java   |  48 +++++
 ....java => AlterTableAddConstraintOperation.java} |  54 +++---
 ...java => AlterTableDropConstraintOperation.java} |  24 +--
 .../org/apache/flink/table/api/TableSchema.java    |   2 +
 .../apache/flink/table/utils/TableSchemaUtils.java |  62 ++++++
 .../apache/flink/table/api/TableSchemaTest.java    |   4 +-
 .../flink/table/utils/TableSchemaUtilsTest.java    |  73 +++++++
 .../operations/SqlToOperationConverter.java        | 105 ++++++++--
 .../operations/SqlToOperationConverterTest.java    | 215 +++++++++++++++++++--
 .../table/planner/catalog/CatalogTableITCase.scala |  16 +-
 .../table/sqlexec/SqlToOperationConverter.java     |   8 +-
 21 files changed, 1159 insertions(+), 226 deletions(-)
 copy flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/{SqlAlterTableRename.java => SqlAlterTableAddConstraint.java} (57%)
 copy flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/{SqlAlterTableRename.java => SqlAlterTableDropConstraint.java} (59%)
 copy flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/{dml/RichSqlInsertKeyword.java => ddl/constraint/SqlConstraintEnforcement.java} (75%)
 create mode 100644 flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/constraint/SqlTableConstraint.java
 copy flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/{dml/RichSqlInsertKeyword.java => ddl/constraint/SqlUniqueSpec.java} (76%)
 copy flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ddl/{DropTableOperation.java => AlterTableAddConstraintOperation.java} (57%)
 copy flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ddl/{AlterTableRenameOperation.java => AlterTableDropConstraintOperation.java} (60%)
 create mode 100644 flink-table/flink-table-common/src/test/java/org/apache/flink/table/utils/TableSchemaUtilsTest.java