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/21 18:53:29 UTC

[iceberg] branch master updated (b7dde31 -> 9aa43a0)

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 b7dde31  Spark: Add Spark extensions to iceberg-spark3-runtime (#2127)
     add 9aa43a0  Spark: Distribute and sort writes in MERGE queries (#2022)

No new revisions were added by this update.

Summary of changes:
 LICENSE                                            |   1 +
 .../java/org/apache/iceberg/TableProperties.java   |   2 +
 .../expressions/TransformExpressions.scala         | 121 ++++++++++++++++++++
 .../sql/catalyst/optimizer/RewriteMergeInto.scala  |  62 ++++++++++-
 .../sql/catalyst/plans/logical/MergeInto.scala     |   7 +-
 .../utils/RewriteRowLevelOperationHelper.scala     | 117 +++++++++++++++++++-
 .../v2/ExtendedDataSourceV2Strategy.scala          |   4 +-
 .../execution/datasources/v2/MergeIntoExec.scala   |   4 +-
 .../spark/extensions/TestMergeIntoTable.java       | 123 ++++++++++++++++++++-
 .../apache/iceberg/spark}/CopySortOrderFields.java |  47 ++++++--
 .../java/org/apache/iceberg/spark/OrderField.java  | 102 +++++++++++++++++
 .../org/apache/iceberg/spark/SortOrderToSpark.java |  62 +++++++++++
 .../java/org/apache/iceberg/spark/Spark3Util.java  |  56 +++++++++-
 .../distributions/ClusteredDistribution.java       |  19 ++--
 .../iceberg/distributions/Distribution.java        |  12 +-
 .../iceberg/distributions/Distributions.java       |  61 ++++++++++
 .../iceberg/distributions/OrderedDistribution.java |  19 ++--
 .../distributions/UnspecifiedDistribution.java     |  12 +-
 .../impl/ClusterDistributionImpl.java              |  24 ++--
 .../impl/OrderedDistributionImpl.java              |  24 ++--
 .../impl/UnspecifiedDistributionImpl.java          |   9 +-
 .../iceberg/expressions/NullOrdering.java          |  12 +-
 .../iceberg/expressions/SortDirection.java         |  24 ++--
 .../connector/iceberg/expressions/SortOrder.java   |  28 +++--
 24 files changed, 835 insertions(+), 117 deletions(-)
 create mode 100644 spark3-extensions/src/main/scala/org/apache/spark/sql/catalyst/expressions/TransformExpressions.scala
 copy {core/src/main/java/org/apache/iceberg => spark3/src/main/java/org/apache/iceberg/spark}/CopySortOrderFields.java (59%)
 create mode 100644 spark3/src/main/java/org/apache/iceberg/spark/OrderField.java
 create mode 100644 spark3/src/main/java/org/apache/iceberg/spark/SortOrderToSpark.java
 copy core/src/main/java/org/apache/iceberg/actions/Action.java => spark3/src/main/java/org/apache/spark/sql/connector/iceberg/distributions/ClusteredDistribution.java (64%)
 copy api/src/main/java/org/apache/iceberg/expressions/UnboundTerm.java => spark3/src/main/java/org/apache/spark/sql/connector/iceberg/distributions/Distribution.java (76%)
 create mode 100644 spark3/src/main/java/org/apache/spark/sql/connector/iceberg/distributions/Distributions.java
 copy core/src/main/java/org/apache/iceberg/actions/Action.java => spark3/src/main/java/org/apache/spark/sql/connector/iceberg/distributions/OrderedDistribution.java (63%)
 copy api/src/main/java/org/apache/iceberg/expressions/UnboundTerm.java => spark3/src/main/java/org/apache/spark/sql/connector/iceberg/distributions/UnspecifiedDistribution.java (74%)
 copy api/src/main/java/org/apache/iceberg/expressions/Predicate.java => spark3/src/main/java/org/apache/spark/sql/connector/iceberg/distributions/impl/ClusterDistributionImpl.java (63%)
 copy api/src/main/java/org/apache/iceberg/expressions/Predicate.java => spark3/src/main/java/org/apache/spark/sql/connector/iceberg/distributions/impl/OrderedDistributionImpl.java (63%)
 copy core/src/main/java/org/apache/iceberg/hadoop/ConfigProperties.java => spark3/src/main/java/org/apache/spark/sql/connector/iceberg/distributions/impl/UnspecifiedDistributionImpl.java (77%)
 copy api/src/main/java/org/apache/iceberg/NullOrder.java => spark3/src/main/java/org/apache/spark/sql/connector/iceberg/expressions/NullOrdering.java (83%)
 copy api/src/main/java/org/apache/iceberg/NullOrder.java => spark3/src/main/java/org/apache/spark/sql/connector/iceberg/expressions/SortDirection.java (67%)
 copy api/src/main/java/org/apache/iceberg/expressions/Bound.java => spark3/src/main/java/org/apache/spark/sql/connector/iceberg/expressions/SortOrder.java (62%)