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/06/28 03:57:48 UTC

[iceberg] branch master updated (7a783b67d -> 23b97c191)

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 7a783b67d MR: Clone ANYWHERE location array IcebergSplit (#4984)
     add 23b97c191 API: Refactor ScanTask hierarchy (#5077)

No new revisions were added by this update.

Summary of changes:
 .../java/org/apache/iceberg/BaseScanTaskGroup.java |  31 ++++--
 .../java/org/apache/iceberg/CombinedScanTask.java  |   7 +-
 .../{FileScanTask.java => ContentScanTask.java}    |  40 ++------
 .../main/java/org/apache/iceberg/FileScanTask.java |  57 ++---------
 .../org/apache/iceberg/IncrementalAppendScan.java  |   2 +-
 .../{HistoryEntry.java => MergeableScanTask.java}  |  27 +++--
 api/src/main/java/org/apache/iceberg/Scan.java     |  43 ++++----
 api/src/main/java/org/apache/iceberg/ScanTask.java |  18 ++++
 .../{CombinedScanTask.java => ScanTaskGroup.java}  |  20 ++--
 ...UpdateLocation.java => SplittableScanTask.java} |  17 ++--
 .../main/java/org/apache/iceberg/TableScan.java    |   2 +-
 .../org/apache/iceberg/BaseCombinedScanTask.java   |   3 +-
 .../java/org/apache/iceberg/BaseFileScanTask.java  |  52 ++--------
 .../apache/iceberg/BaseIncrementalAppendScan.java  |   4 +-
 .../src/main/java/org/apache/iceberg/BaseScan.java |  20 ++--
 .../java/org/apache/iceberg/BaseTableScan.java     |   2 +-
 .../org/apache/iceberg/util/TableScanUtil.java     |  69 +++++++++++++
 .../test/java/org/apache/iceberg/ScanTestBase.java |   2 +-
 .../org/apache/iceberg/util/TestTableScanUtil.java | 111 +++++++++++++++++++++
 .../iceberg/flink/source/FlinkSplitPlanner.java    |   3 +-
 .../iceberg/flink/source/FlinkSplitPlanner.java    |   3 +-
 .../java/org/apache/iceberg/TaskCheckHelper.java   |   6 +-
 .../apache/iceberg/TestScanTaskSerialization.java  |  58 ++++++++++-
 23 files changed, 397 insertions(+), 200 deletions(-)
 copy core/src/main/java/org/apache/iceberg/BaseCombinedScanTask.java => api/src/main/java/org/apache/iceberg/BaseScanTaskGroup.java (67%)
 copy api/src/main/java/org/apache/iceberg/{FileScanTask.java => ContentScanTask.java} (64%)
 copy api/src/main/java/org/apache/iceberg/{HistoryEntry.java => MergeableScanTask.java} (60%)
 copy api/src/main/java/org/apache/iceberg/{CombinedScanTask.java => ScanTaskGroup.java} (66%)
 copy api/src/main/java/org/apache/iceberg/{UpdateLocation.java => SplittableScanTask.java} (56%)