This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 5e1129ab7c [python] Refactor SplitBase to Split
5e1129ab7c is described below
commit 5e1129ab7c274e087834a90650caf8c4c25f9054
Author: JingsongLi <[email protected]>
AuthorDate: Wed Jan 14 23:34:31 2026 +0800
[python] Refactor SplitBase to Split
---
paimon-python/pypaimon/globalindex/indexed_split.py | 4 ++--
paimon-python/pypaimon/read/scanner/full_starting_scanner.py | 4 ++--
paimon-python/pypaimon/read/scanner/split_generator.py | 3 ++-
paimon-python/pypaimon/read/sliced_split.py | 4 ++--
paimon-python/pypaimon/read/split.py | 4 ++--
5 files changed, 10 insertions(+), 9 deletions(-)
diff --git a/paimon-python/pypaimon/globalindex/indexed_split.py
b/paimon-python/pypaimon/globalindex/indexed_split.py
index 0203923fc7..6c58a6fc5a 100644
--- a/paimon-python/pypaimon/globalindex/indexed_split.py
+++ b/paimon-python/pypaimon/globalindex/indexed_split.py
@@ -22,10 +22,10 @@ IndexedSplit wraps a Split with row ranges and optional
scores.
from typing import List, Optional
-from pypaimon.read.split import SplitBase
+from pypaimon.read.split import Split
-class IndexedSplit(SplitBase):
+class IndexedSplit(Split):
def __init__(
self,
diff --git a/paimon-python/pypaimon/read/scanner/full_starting_scanner.py
b/paimon-python/pypaimon/read/scanner/full_starting_scanner.py
index e4fdb5d16b..f415ab61ef 100755
--- a/paimon-python/pypaimon/read/scanner/full_starting_scanner.py
+++ b/paimon-python/pypaimon/read/scanner/full_starting_scanner.py
@@ -32,7 +32,7 @@ from pypaimon.read.scanner.append_table_split_generator
import AppendTableSplitG
from pypaimon.read.scanner.data_evolution_split_generator import
DataEvolutionSplitGenerator
from pypaimon.read.scanner.primary_key_table_split_generator import
PrimaryKeyTableSplitGenerator
from pypaimon.read.scanner.starting_scanner import StartingScanner
-from pypaimon.read.split import Split
+from pypaimon.read.split import DataSplit
from pypaimon.snapshot.snapshot_manager import SnapshotManager
from pypaimon.table.bucket_mode import BucketMode
from pypaimon.manifest.simple_stats_evolutions import SimpleStatsEvolutions
@@ -240,7 +240,7 @@ class FullStartingScanner(StartingScanner):
self.end_pos_of_this_subtask = end_pos
return self
- def _apply_push_down_limit(self, splits: List[Split]) -> List[Split]:
+ def _apply_push_down_limit(self, splits: List[DataSplit]) ->
List[DataSplit]:
if self.limit is None:
return splits
scanned_row_count = 0
diff --git a/paimon-python/pypaimon/read/scanner/split_generator.py
b/paimon-python/pypaimon/read/scanner/split_generator.py
index 8f94338900..6dab4fc12a 100644
--- a/paimon-python/pypaimon/read/scanner/split_generator.py
+++ b/paimon-python/pypaimon/read/scanner/split_generator.py
@@ -21,6 +21,7 @@ from typing import Callable, List, Optional, Dict, Tuple
from pypaimon.manifest.schema.data_file_meta import DataFileMeta
from pypaimon.manifest.schema.manifest_entry import ManifestEntry
from pypaimon.read.split import Split
+from pypaimon.read.split import DataSplit
from pypaimon.table.row.generic_row import GenericRow
from pypaimon.table.source.deletion_file import DeletionFile
@@ -121,7 +122,7 @@ class AbstractSplitGenerator(ABC):
file_entries[0].bucket
)
- split = Split(
+ split = DataSplit(
files=file_group,
partition=file_entries[0].partition,
bucket=file_entries[0].bucket,
diff --git a/paimon-python/pypaimon/read/sliced_split.py
b/paimon-python/pypaimon/read/sliced_split.py
index ff96798633..7d8e3a04d1 100644
--- a/paimon-python/pypaimon/read/sliced_split.py
+++ b/paimon-python/pypaimon/read/sliced_split.py
@@ -22,10 +22,10 @@ SlicedSplit wraps a Split with file index ranges for
shard/slice processing.
from typing import List, Dict, Tuple
-from pypaimon.read.split import SplitBase
+from pypaimon.read.split import Split
-class SlicedSplit(SplitBase):
+class SlicedSplit(Split):
"""
Wrapper for Split that adds file-level slicing information.
diff --git a/paimon-python/pypaimon/read/split.py
b/paimon-python/pypaimon/read/split.py
index 3daccb75f3..3f2d2f8329 100644
--- a/paimon-python/pypaimon/read/split.py
+++ b/paimon-python/pypaimon/read/split.py
@@ -24,7 +24,7 @@ from pypaimon.table.row.generic_row import GenericRow
from pypaimon.table.source.deletion_file import DeletionFile
-class SplitBase(ABC):
+class Split(ABC):
"""
Base interface for Split following Java's
org.apache.paimon.table.source.Split.
@@ -56,7 +56,7 @@ class SplitBase(ABC):
pass
-class Split(SplitBase):
+class DataSplit(Split):
"""
Implementation of Split for native Python reading.
