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
