We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
bound_filter
1 parent 02f8e22 commit bf262e6Copy full SHA for bf262e6
1 file changed
pyiceberg/table/__init__.py
@@ -1495,6 +1495,7 @@ def __init__(
1495
snapshot_id: Optional[int] = None,
1496
options: Properties = EMPTY_DICT,
1497
limit: Optional[int] = None,
1498
+ bound_filter: Optional[BooleanExpression] = None
1499
):
1500
self.table_metadata = table_metadata
1501
self.io = io
@@ -1504,7 +1505,7 @@ def __init__(
1504
1505
self.snapshot_id = snapshot_id
1506
self.options = options
1507
self.limit = limit
- self.bound_filter = bind(self.table_metadata.schema(), rewrite_not(self.row_filter), self.case_sensitive)
1508
+ self.bound_filter = bound_filter or bind(self.table_metadata.schema(), rewrite_not(self.row_filter), self.case_sensitive)
1509
1510
def snapshot(self) -> Optional[Snapshot]:
1511
if self.snapshot_id:
0 commit comments