This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a commit to branch release-1.3 in repository https://gitbox.apache.org/repos/asf/paimon.git
commit f58f0f5e99d93ffe6110f126264cd98246ef59b4 Author: JingsongLi <[email protected]> AuthorDate: Thu Oct 23 16:55:02 2025 +0800 [python] Use _try_to_pad_batch_by_schema in TableRead --- paimon-python/pypaimon/read/table_read.py | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/paimon-python/pypaimon/read/table_read.py b/paimon-python/pypaimon/read/table_read.py index cbc80faa28..15aaf35462 100644 --- a/paimon-python/pypaimon/read/table_read.py +++ b/paimon-python/pypaimon/read/table_read.py @@ -57,7 +57,11 @@ class TableRead: batch_iterator = self._arrow_batch_generator(splits, schema) return pyarrow.ipc.RecordBatchReader.from_batches(schema, batch_iterator) - def _pad_batch_to_schema(self, batch: pyarrow.RecordBatch, target_schema): + @staticmethod + def _try_to_pad_batch_by_schema(batch: pyarrow.RecordBatch, target_schema): + if batch.schema.names == target_schema.names: + return batch + columns = [] num_rows = batch.num_rows @@ -76,8 +80,7 @@ class TableRead: schema = PyarrowFieldParser.from_paimon_schema(self.read_type) table_list = [] for batch in iter(batch_reader.read_next_batch, None): - table_list.append(batch) if schema == batch.schema \ - else table_list.append(self._pad_batch_to_schema(batch, schema)) + table_list.append(self._try_to_pad_batch_by_schema(batch, schema)) if not table_list: return pyarrow.Table.from_arrays([pyarrow.array([], type=field.type) for field in schema], schema=schema)
