You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iceberg.apache.org by bl...@apache.org on 2021/01/22 20:48:34 UTC
[iceberg] branch master updated (e58eba1 -> ca0c7a2)
This is an automated email from the ASF dual-hosted git repository.
blue pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git.
from e58eba1 Flink: Support SQL IF EXISTS and IF NOT EXISTS clauses (#2135)
add ca0c7a2 Spark: Rewrite MERGE INTO and DELETE for only Iceberg tables (#2134)
No new revisions were added by this update.
Summary of changes:
.../catalyst/analysis/AlignMergeIntoTable.scala | 3 +-
.../analysis/DeleteFromTablePredicateCheck.scala | 3 +-
.../analysis/MergeIntoTablePredicateCheck.scala | 3 +-
.../OptimizeConditionsInRowLevelOperations.scala | 4 ++-
...pCorrelatedPredicatesInRowLevelOperations.scala | 3 +-
.../sql/catalyst/optimizer/RewriteDelete.scala | 6 ++--
.../sql/catalyst/optimizer/RewriteMergeInto.scala | 12 ++++---
.../{SetAccumulator.scala => PlanUtils.scala} | 39 ++++++++++------------
.../iceberg/spark/extensions/TestDelete.java | 9 +++++
.../apache/iceberg/spark/extensions/TestMerge.java | 15 +++++++++
10 files changed, 63 insertions(+), 34 deletions(-)
copy spark3-extensions/src/main/scala/org/apache/spark/sql/catalyst/utils/{SetAccumulator.scala => PlanUtils.scala} (56%)