This is an automated email from the ASF dual-hosted git repository.
JingsongLi pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/paimon-rust.git
The following commit(s) were added to refs/heads/main by this push:
new 99b446f0 fix(python): declare abort and default_database in the type
stub (#683)
99b446f0 is described below
commit 99b446f06a4f2f4fccef3f69dad05a15f9ee4309
Author: jackylee <[email protected]>
AuthorDate: Thu Aug 6 20:53:12 2026 +0800
fix(python): declare abort and default_database in the type stub (#683)
---
bindings/python/python/pypaimon_rust/datafusion.pyi | 19 ++++++++++++++++---
1 file changed, 16 insertions(+), 3 deletions(-)
diff --git a/bindings/python/python/pypaimon_rust/datafusion.pyi
b/bindings/python/python/pypaimon_rust/datafusion.pyi
index f134c274..e7cbb929 100644
--- a/bindings/python/python/pypaimon_rust/datafusion.pyi
+++ b/bindings/python/python/pypaimon_rust/datafusion.pyi
@@ -66,7 +66,10 @@ class ReadBuilder:
set before ``with_filter`` for the filter to honor it.
"""
...
- def with_limit(self, limit: int) -> "ReadBuilder": ...
+ def with_limit(self, limit: int) -> "ReadBuilder":
+ """Set a scan-planning row-limit hint, not an exact cap: a matching
split is
+ returned whole. Apply application-level limiting for an exact bound."""
+ ...
def with_filter(self, predicate: dict) -> "ReadBuilder": ...
def with_row_ranges(self, ranges: Sequence[tuple[int, int]]) ->
"ReadBuilder":
"""Set Data Evolution row ranges. Empty selects no rows; format tables
are unsupported."""
@@ -139,6 +142,10 @@ class TableWrite:
class TableCommit:
def commit(self, messages: Sequence[CommitMessage]) -> None: ...
+ def abort(self, messages: Sequence[CommitMessage]) -> None:
+ """Delete the files the messages refer to. Best-effort: missing files
and
+ storage errors are ignored. The messages must not be committed
afterwards."""
+ ...
class WriteBuilder:
def new_write(self) -> TableWrite: ...
@@ -198,8 +205,14 @@ class SQLContext:
max_temp_directory_size_bytes: Optional[int] = None,
) -> None: ...
def register_catalog(
- self, catalog_name: str, catalog_options: Dict[str, str]
- ) -> None: ...
+ self,
+ catalog_name: str,
+ catalog_options: Dict[str, str],
+ default_database: Optional[str] = None,
+ ) -> None:
+ """Register a Paimon catalog. ``default_database``: omitted or
``None`` uses
+ ``"default"``; ``""`` skips default-database init; a name uses that
database."""
+ ...
def set_current_catalog(self, catalog_name: str) -> None: ...
def set_current_database(self, database_name: str) -> None: ...
def register_batch(self, name: str, batch: pyarrow.RecordBatch) -> None:
...
