You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by li...@apache.org on 2023/01/30 08:29:55 UTC
[flink] branch master updated (6d17ba88556 -> 5afc301bc64)

This is an automated email from the ASF dual-hosted git repository.

lincoln pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


    from 6d17ba88556 [FLINK-29558][table-planner] Fix projection pushdown rule select nothing from source when no column is needed logically (#21704)
     add 5afc301bc64 [FLINK-30665][table] Planner supports row-level update

No new revisions were added by this update.

Summary of changes:
 .../table/planner/connectors/DynamicSinkUtils.java | 175 +++-
 .../operations/SqlToOperationConverter.java        |  25 +-
 .../plan/abilities/sink/RowLevelDeleteSpec.java    |   1 +
 ...evelDeleteSpec.java => RowLevelUpdateSpec.java} |  55 +-
 .../plan/abilities/sink/SinkAbilitySpec.java       |   3 +-
 .../plan/nodes/exec/common/CommonExecSink.java     |  10 +-
 .../factories/TestUpdateDeleteTableFactory.java    | 398 +++++++--
 ...st.java => SqlDdlToOperationConverterTest.java} | 701 +--------------
 .../operations/SqlDmlToOperationConverterTest.java | 334 +++++++
 .../operations/SqlOtherOperationConverterTest.java | 324 +++++++
 .../SqlToOperationConverterTestBase.java           | 148 ++++
 .../planner/plan/batch/sql/RowLevelUpdateTest.java | 165 ++++
 .../runtime/batch/sql/UpdateTableITCase.java       | 150 ++++
 .../runtime/stream/sql/UpdateTableITCase.java      |  44 +
 .../planner/plan/batch/sql/RowLevelUpdateTest.xml  | 973 +++++++++++++++++++++
 15 files changed, 2748 insertions(+), 758 deletions(-)
 copy flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/abilities/sink/{RowLevelDeleteSpec.java => RowLevelUpdateSpec.java} (60%)
 rename flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/{SqlToOperationConverterTest.java => SqlDdlToOperationConverterTest.java} (79%)
 create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/SqlDmlToOperationConverterTest.java
 create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/SqlOtherOperationConverterTest.java
 create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/operations/SqlToOperationConverterTestBase.java
 create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/batch/sql/RowLevelUpdateTest.java
 create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/batch/sql/UpdateTableITCase.java
 create mode 100644 flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/stream/sql/UpdateTableITCase.java
 create mode 100644 flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/batch/sql/RowLevelUpdateTest.xml