[SERVER-82207] Streams: Partition input document batch in window operator by window timestamp Created: 16/Oct/23 Updated: 31/Oct/23 Resolved: 31/Oct/23 |
|
| Status: | Closed |
| Project: | Core Server |
| Component/s: | None |
| Affects Version/s: | None |
| Fix Version/s: | None |
| Type: | Task | Priority: | Major - P3 |
| Reporter: | Aadesh Patel (Inactive) | Assignee: | Aadesh Patel (Inactive) |
| Resolution: | Fixed | Votes: | 0 |
| Labels: | None | ||
| Remaining Estimate: | Not Specified | ||
| Time Spent: | Not Specified | ||
| Original Estimate: | Not Specified | ||
| Assigned Teams: |
Atlas Streams
|
| Backwards Compatibility: | Fully Compatible |
| Sprint: | Sprint 33, Sprint 34, Sprint 35 |
| Participants: |
| Description |
|
Right now we process each document one by one in the window operator and propagate only one document at a time. Instead we should partition the batch based on the windows that they belong in so that we only send a single message with multiple documents for a window. |