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 2022/12/02 23:54:23 UTC

[iceberg] branch master updated (a980d76546 -> 7fd9ded0a1)

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 a980d76546 Build: Keep Scala Compiler Alive Between Sessions(#6311)
     add 7fd9ded0a1 Spark 3.3: Choose readers based on task types (#6345)

No new revisions were added by this update.

Summary of changes:
 .../iceberg/spark/source/BatchDataReader.java      |  33 ++++-
 .../iceberg/spark/source/ChangelogRowReader.java   |  13 +-
 .../spark/source/EqualityDeleteRowReader.java      |   2 +-
 .../apache/iceberg/spark/source/RowDataReader.java |  34 ++++-
 .../apache/iceberg/spark/source/SparkBatch.java    |  15 ++-
 .../iceberg/spark/source/SparkChangelogBatch.java  | 138 ---------------------
 .../iceberg/spark/source/SparkChangelogScan.java   |   8 +-
 .../spark/source/SparkColumnarReaderFactory.java   |  64 ++++++++++
 .../iceberg/spark/source/SparkInputPartition.java  |   4 +
 .../spark/source/SparkMicroBatchStream.java        |   3 +-
 .../spark/source/SparkRowReaderFactory.java        |  64 ++++++++++
 .../org/apache/iceberg/spark/source/SparkScan.java |  92 --------------
 12 files changed, 218 insertions(+), 252 deletions(-)
 delete mode 100644 spark/v3.3/spark/src/main/java/org/apache/iceberg/spark/source/SparkChangelogBatch.java
 create mode 100644 spark/v3.3/spark/src/main/java/org/apache/iceberg/spark/source/SparkColumnarReaderFactory.java
 create mode 100644 spark/v3.3/spark/src/main/java/org/apache/iceberg/spark/source/SparkRowReaderFactory.java