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

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


    from bda3eb031b [python] with_shard should be evenly distributed for data 
evolution mode (#7271)
     add ba209f88d3 [core][python] Introduce DataFileMeta.nonNullRowIdRange to 
unify codes

No new revisions were added by this update.

Summary of changes:
 .../java/org/apache/paimon/utils/RangeHelper.java  | 21 ++++++------
 .../DataEvolutionCompactCoordinator.java           | 14 +++-----
 .../paimon/globalindex/DataEvolutionBatchScan.java |  5 +--
 .../globalindex/btree/BTreeGlobalIndexBuilder.java |  6 ++--
 .../java/org/apache/paimon/io/DataFileMeta.java    |  5 +++
 .../org/apache/paimon/io/PojoDataFileMeta.java     |  8 ++---
 .../apache/paimon/manifest/SimpleFileEntry.java    |  6 ++++
 .../operation/DataEvolutionFileStoreScan.java      |  4 +--
 .../paimon/operation/DataEvolutionSplitRead.java   |  6 ++--
 .../paimon/operation/commit/ConflictDetection.java |  9 ++---
 .../table/source/DataEvolutionSplitGenerator.java  |  5 +--
 .../org/apache/paimon/table/source/DataSplit.java  |  5 +--
 paimon-python/pypaimon/globalindex/__init__.py     |  2 +-
 .../pypaimon/globalindex/global_index_result.py    |  2 +-
 .../globalindex/global_index_scan_builder.py       |  2 +-
 .../globalindex/global_index_scan_builder_impl.py  |  2 +-
 .../pypaimon/manifest/schema/data_file_meta.py     |  6 ++++
 .../read/reader/row_range_filter_record_reader.py  |  2 +-
 .../read/scanner/data_evolution_split_generator.py | 31 +++++-------------
 .../pypaimon/read/scanner/file_scanner.py          | 12 +++----
 paimon-python/pypaimon/read/sliced_split.py        |  2 +-
 paimon-python/pypaimon/read/split.py               | 38 +++-------------------
 paimon-python/pypaimon/read/split_read.py          |  3 +-
 paimon-python/pypaimon/tests/range_test.py         |  2 +-
 .../pypaimon/{globalindex => utils}/range.py       |  0
 paimon-python/pypaimon/utils/roaring_bitmap.py     |  2 +-
 paimon-python/pypaimon/write/file_store_commit.py  | 11 +++----
 paimon-python/pypaimon/write/table_update.py       |  8 ++---
 .../globalindex/DefaultGlobalIndexTopoBuilder.java | 12 +++----
 29 files changed, 84 insertions(+), 147 deletions(-)
 rename paimon-python/pypaimon/{globalindex => utils}/range.py (100%)

Reply via email to