smaheshwar-pltr commented on code in PR #2234:
URL: https://github.com/apache/iceberg-python/pull/2234#discussion_r2222507974
##########
pyiceberg/table/__init__.py:
##########
@@ -1139,6 +1143,60 @@ def scan(
limit=limit,
)
+ def incremental_append_scan(
+ self,
+ row_filter: Union[str, BooleanExpression] = ALWAYS_TRUE,
+ selected_fields: Tuple[str, ...] = ("*",),
+ case_sensitive: bool = True,
+ from_snapshot_id_exclusive: Optional[int] = None,
+ to_snapshot_id_inclusive: Optional[int] = None,
+ options: Properties = EMPTY_DICT,
+ limit: Optional[int] = None,
+ ) -> IncrementalAppendScan:
+ """Fetch an IncrementalAppendScan based on the table's current
metadata.
+
+ The incremental append scan can be used to project the table's data
+ from append snapshots within a snapshot range and that matches the
+ provided row_filter onto the table's current schema
+
+ Args:
+ row_filter:
+ A string or BooleanExpression that describes the
+ desired rows
+ selected_fields:
+ A tuple of strings representing the column names
+ to return in the output dataframe.
+ case_sensitive:
+ If True column matching is case sensitive
+ from_snapshot_id_exclusive:
+ Optional ID of the "from" snapshot, to start the incremental
scan from, exclusively. This can be set
+ on the IncrementalAppendScan object returned, but ultimately
must not be None.
Review Comment:
https://github.com/apache/iceberg-python/pull/2031#discussion_r2102674779
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
