arunpandianp opened a new pull request, #38767:
URL: https://github.com/apache/beam/pull/38767
- Add Uint128Proto and key_group to WorkItem in windmill.proto.
- Update Work model to support key groups.
- Implement KeyGroupWorkQueue for grouping tasks by key group.
KepGroupWorkQueue is a FIFO queue that allows polling elements based on global
order and also by order within a key group.
- Integrate BoundedQueueExecutor with KepGroupWorkQueue and support
targeted polling.
The changes are behind an experiment `unstable_enable_multi_key_bundle`
and does not affect the default core logic.
--
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]
