You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iceberg.apache.org by ao...@apache.org on 2021/12/01 18:29:40 UTC
[iceberg] branch master updated (b67f317 -> f527b1a)

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

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


    from b67f317  Core: Handle metrics-based deletes (#3600)
     add f527b1a  Spark: Add connector APIs for row-level commands (#3633)

No new revisions were added by this update.

Summary of changes:
 .../connector/iceberg/write/DeltaBatchWrite.java   | 21 ++---
 .../sql/connector/iceberg/write/DeltaWrite.java}   | 25 ++----
 .../connector/iceberg/write/DeltaWriteBuilder.java | 18 ++---
 .../sql/connector/iceberg/write/DeltaWriter.java   | 60 +++++++++++++++
 .../iceberg/write/DeltaWriterFactory.java          | 21 ++---
 .../iceberg/write/ExtendedLogicalWriteInfo.java}   | 20 ++---
 .../connector/iceberg/write/RowLevelOperation.java | 89 ++++++++++++++++++++++
 .../iceberg/write/RowLevelOperationBuilder.java    | 15 ++--
 .../iceberg/write/RowLevelOperationInfo.java}      | 20 ++---
 .../connector/iceberg/write/SupportsDelta.java}    | 22 ++----
 10 files changed, 211 insertions(+), 100 deletions(-)
 copy api/src/main/java/org/apache/iceberg/NullOrder.java => spark/v3.2/spark/src/main/java/org/apache/spark/sql/connector/iceberg/write/DeltaBatchWrite.java (67%)
 copy spark/{v3.0/spark/src/main/java/org/apache/spark/sql/connector/iceberg/write/MergeBuilder.java => v3.2/spark/src/main/java/org/apache/spark/sql/connector/iceberg/write/DeltaWrite.java} (63%)
 copy orc/src/main/java/org/apache/iceberg/orc/OrcBatchReader.java => spark/v3.2/spark/src/main/java/org/apache/spark/sql/connector/iceberg/write/DeltaWriteBuilder.java (69%)
 create mode 100644 spark/v3.2/spark/src/main/java/org/apache/spark/sql/connector/iceberg/write/DeltaWriter.java
 copy api/src/main/java/org/apache/iceberg/NullOrder.java => spark/v3.2/spark/src/main/java/org/apache/spark/sql/connector/iceberg/write/DeltaWriterFactory.java (67%)
 copy spark/{v3.1/spark/src/main/java/org/apache/spark/sql/connector/iceberg/write/MergeBuilder.java => v3.2/spark/src/main/java/org/apache/spark/sql/connector/iceberg/write/ExtendedLogicalWriteInfo.java} (66%)
 create mode 100644 spark/v3.2/spark/src/main/java/org/apache/spark/sql/connector/iceberg/write/RowLevelOperation.java
 copy orc/src/main/java/org/apache/iceberg/orc/OrcRowReader.java => spark/v3.2/spark/src/main/java/org/apache/spark/sql/connector/iceberg/write/RowLevelOperationBuilder.java (74%)
 copy spark/{v3.0/spark/src/main/java/org/apache/spark/sql/connector/iceberg/write/MergeBuilder.java => v3.2/spark/src/main/java/org/apache/spark/sql/connector/iceberg/write/RowLevelOperationInfo.java} (64%)
 copy spark/{v3.0/spark/src/main/java/org/apache/spark/sql/connector/iceberg/write/MergeBuilder.java => v3.2/spark/src/main/java/org/apache/spark/sql/connector/iceberg/write/SupportsDelta.java} (65%)