xiangfu0 opened a new pull request, #17811: URL: https://github.com/apache/pinot/pull/17811
## Summary - Introduces a new `StreamMetadata` class in `pinot-spi` that groups `PartitionGroupMetadata` per stream, replacing the flat `List<PartitionGroupMetadata>` pattern - Each `StreamMetadata` carries the `StreamConfig`, stream config index, and the list of partition group metadata for that stream - Eliminates the need for callers to decode Pinot partition IDs (via the `streamIndex * 10000 + streamPartitionId` padding scheme) to determine stream ownership - Updates `PartitionGroupMetadataFetcher`, `PinotTableIdealStateBuilder`, `PinotLLCRealtimeSegmentManager`, and `MissingConsumingSegmentFinder` to use the new grouped type ## Test plan - [x] `PartitionGroupMetadataFetcherTest` — 4/4 tests pass (updated to verify per-stream grouping) - [x] `PinotLLCRealtimeSegmentManagerTest` — 33/33 tests pass (updated `FakePinotLLCRealtimeSegmentManager` overrides) - [x] `MissingConsumingSegmentFinderTest` — 6/6 tests pass 🤖 Generated with [Claude Code](https://claude.com/claude-code) -- 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] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
