refactor(streaming): use bitmap builder for dispatcher visibility

[BugenZhao]

Signed-off-by: Bugen Zhao i@bugenzhao.com

I hereby agree to the terms of the Singularity Data, Inc. Contributor License Agreement.

What's changed and what's your intention?

As title. 💦

Checklist

• I have written necessary docs and comments
• I have added necessary unit tests and integration tests
• All checks passed in ./risedev check (or alias, ./risedev c)

Refer to a related PR or issue link (optional)

• Enable consistent hash for HashAgg #3544

[codecov]

Codecov Report

Merging #3546 (b9af523) into main (e1e27e5) will decrease coverage by 0.00%.
The diff coverage is 100.00%.

@@            Coverage Diff             @@
##             main    #3546      +/-   ##
==========================================
- Coverage   74.41%   74.41%   -0.01%     
==========================================
  Files         770      770              
  Lines      108659   108657       -2     
==========================================
- Hits        80858    80853       -5     
- Misses      27801    27804       +3     

Flag	Coverage Δ
rust	74.41% <100.00%> (-0.01%)	⬇️

Flags with carried forward coverage won't be shown. Click here to find out more.

Impacted Files	Coverage Δ
src/stream/src/executor/dispatch.rs	77.29% <100.00%> (-0.07%)	⬇️
src/meta/src/manager/id.rs	94.94% <0.00%> (-1.13%)	⬇️
src/meta/src/hummock/mock_hummock_meta_client.rs	40.56% <0.00%> (-0.95%)	⬇️
src/common/src/types/ordered_float.rs	24.70% <0.00%> (-0.20%)	⬇️
src/storage/src/hummock/local_version_manager.rs	79.15% <0.00%> (-0.13%)	⬇️
src/connector/src/filesystem/file_common.rs	80.80% <0.00%> (+0.44%)	⬆️
src/storage/src/hummock/iterator/merge_inner.rs	90.00% <0.00%> (+0.62%)	⬆️

📣 Codecov can now indicate which changes are the most critical in Pull Requests. Learn more

[chinawch007]

Excuse me, what are the functions of 'DispatchExecutor'?

[BugenZhao]

Excuse me, what are the functions of 'DispatchExecutor'?

It's used for message passing between different streaming actors. BTW, you may join our Slack community at README.md if you are interested in RisingWave internals. 😄

[TennyZhuang]

Please resolve conflicts

[chinawch007]

Excuse me, what are the functions of 'DispatchExecutor'?

It's used for message passing between different streaming actors. BTW, you may join our Slack community at README.md if you are interested in RisingWave internals. 😄

Thanks for help, I have joined the Slack community.😊