You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iceberg.apache.org by fo...@apache.org on 2025/04/23 05:49:34 UTC
(iceberg-python) 02/02: WIP
This is an automated email from the ASF dual-hosted git repository.
fokko pushed a commit to branch fd-integrate-residuals
in repository https://gitbox.apache.org/repos/asf/iceberg-python.git
commit afdfef2fe5542b6d02b09c96193d3df8354e14b5
Author: Fokko <fo...@apache.org>
AuthorDate: Wed Apr 23 07:49:09 2025 +0200
WIP
---
pyiceberg/table/__init__.py | 3 +--
tests/io/test_pyarrow.py | 1 -
2 files changed, 1 insertion(+), 3 deletions(-)
diff --git a/pyiceberg/table/__init__.py b/pyiceberg/table/__init__.py
index 3d5c04d0..50535102 100644
--- a/pyiceberg/table/__init__.py
+++ b/pyiceberg/table/__init__.py
@@ -1796,7 +1796,7 @@ class DataScan(TableScan):
from pyiceberg.io.pyarrow import ArrowScan
return ArrowScan(
- self.table_metadata, self.io, self.projection(), self.row_filter, self.case_sensitive, self.limit
+ self.table_metadata, self.io, self.projection(), case_sensitive=self.case_sensitive, limit=self.limit
).to_table(self.plan_files())
def to_arrow_batch_reader(self) -> pa.RecordBatchReader:
@@ -1889,7 +1889,6 @@ class DataScan(TableScan):
table_metadata=self.table_metadata,
io=self.io,
projected_schema=self.projection(),
- row_filter=self.row_filter,
case_sensitive=self.case_sensitive,
)
tbl = arrow_scan.to_table([task])
diff --git a/tests/io/test_pyarrow.py b/tests/io/test_pyarrow.py
index f5b72b77..7b115c6a 100644
--- a/tests/io/test_pyarrow.py
+++ b/tests/io/test_pyarrow.py
@@ -972,7 +972,6 @@ def project(
),
io=PyArrowFileIO(),
projected_schema=schema,
- row_filter=expr or AlwaysTrue(),
case_sensitive=True,
).to_table(
tasks=[