apache / apache/fluss-rust

[rust] Lookuper / PrefixKeyLookuper: switch to &self lookup for pipelining

Open
#541 0 comments 0 reactions 0 assignees View on GitHub
Dominant language
Rust
Stars
58
Forks
50
PR merge metrics
No merged PRs in 30d

Description

### Search before asking

- [x] I searched in the [issues](https://github.com/apache/fluss-rust/issues) and found nothing similar.

### Description

`Lookuper::lookup` and `PrefixKeyLookuper::lookup` take `&mut self`, forcing bindings to hold a mutex across the network `.await`. Concurrent lookups on one instance serialize end-to-end. On the other hand Java pipelines on a single lookuper.

We can wrap encoder in `parking_lot::Mutex`, make `lookup` `&self`, release the lock before `.await`
Also align with bindings(1-5 lines wiring probably required)

### Willingness to contribute

- [ ] I'm willing to submit a PR!

Contributor guide

No contributing guide indexed for this repository

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.