This is an automated email from the ASF dual-hosted git repository.
yuxia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 522fac5c1d0 [FLINK-29542][docs] Fix typos in unload.md
add 6695d84dbb7 [FLINK-32001][table] Row-level update should support
returning partial columns (#22525)
No new revisions were added by this update.
Summary of changes:
.../src/test/resources/sql/delete.q | 2 +-
.../table/planner/connectors/DynamicSinkUtils.java | 134 +++++++++++++--------
.../plan/abilities/sink/RowLevelDeleteSpec.java | 27 ++++-
.../plan/abilities/sink/RowLevelUpdateSpec.java | 25 +++-
.../plan/nodes/exec/batch/BatchExecSink.java | 66 ++++++++++
.../plan/nodes/exec/common/CommonExecSink.java | 4 +-
.../factories/TestUpdateDeleteTableFactory.java | 125 ++++++++++++++++---
.../runtime/batch/sql/DeleteTableITCase.java | 47 +++++++-
.../runtime/batch/sql/UpdateTableITCase.java | 40 ++++++
9 files changed, 385 insertions(+), 85 deletions(-)
