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%)