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 ba2a215064 Spark 3.3: Support write to branch through table identifier
(#6965)
add 81f2510db7 Spark 3.3: Add SparkStagedScan to replace SparkFilesScan
(#6924)
No new revisions were added by this update.
Summary of changes:
.../org/apache/iceberg/util/TableScanUtil.java | 6 +++
.../iceberg/spark/FileScanTaskSetManager.java | 2 +
...TaskSetManager.java => ScanTaskSetManager.java} | 37 +++++++------
.../org/apache/iceberg/spark/SparkReadConf.java | 6 +++
.../org/apache/iceberg/spark/SparkReadOptions.java | 11 +++-
.../iceberg/spark/source/SparkFilesScan.java | 2 +
.../spark/source/SparkFilesScanBuilder.java | 2 +
.../iceberg/spark/source/SparkStagedScan.java} | 60 ++++++++++------------
...canBuilder.java => SparkStagedScanBuilder.java} | 6 +--
.../apache/iceberg/spark/source/SparkTable.java | 4 ++
.../spark/source/TestPositionDeletesTable.java | 44 ++++++++++++++++
...parkFilesScan.java => TestSparkStagedScan.java} | 17 +++---
12 files changed, 133 insertions(+), 64 deletions(-)
copy
spark/v3.3/spark/src/main/java/org/apache/iceberg/spark/{FileScanTaskSetManager.java
=> ScanTaskSetManager.java} (62%)
copy
spark/{v3.2/spark/src/main/java/org/apache/iceberg/spark/source/SparkFilesScan.java
=>
v3.3/spark/src/main/java/org/apache/iceberg/spark/source/SparkStagedScan.java}
(53%)
copy
spark/v3.3/spark/src/main/java/org/apache/iceberg/spark/source/{SparkFilesScanBuilder.java
=> SparkStagedScanBuilder.java} (87%)
rename
spark/v3.3/spark/src/test/java/org/apache/iceberg/spark/source/{TestSparkFilesScan.java
=> TestSparkStagedScan.java} (88%)
