Skip to content

Conversation

@fresh-borzoni
Copy link
Contributor

@fresh-borzoni fresh-borzoni commented Feb 7, 2026

Summary

closes #276

  • Add unsubscribe_partition method to python bindings

@fresh-borzoni
Copy link
Contributor Author

@luoyuxia @leekeiabstraction PTAL 🙏

Copy link

Copilot AI left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Pull request overview

Adds the missing unsubscribe_partition API to the Python bindings so Python users can mirror the unsubscribe functionality already available in the C++ and Rust clients.

Changes:

  • Add LogScanner.unsubscribe_partition(partition_id, bucket_id) to the PyO3 bindings.
  • Update Python type stubs (.pyi) to include the new method.
  • Extend the Python example to demonstrate unsubscribing from a partition and reading remaining partitions.

Reviewed changes

Copilot reviewed 3 out of 3 changed files in this pull request and generated 2 comments.

File Description
bindings/python/src/table.rs Exposes unsubscribe_partition on the Python LogScanner, dispatching to either record or batch scanner implementation.
bindings/python/fluss/init.pyi Adds the unsubscribe_partition method to Python type hints/stubs.
bindings/python/example/example.py Demonstrates unsubscribing from a partition and reading remaining data via to_arrow().

💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.

Copy link
Contributor

@luoyuxia luoyuxia left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@fresh-borzoni Thanks. LGTM!

@luoyuxia luoyuxia merged commit ff879b9 into apache:main Feb 8, 2026
19 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Add unsubscribe_partition in python bindings

2 participants