Abhishek Radhakrishnan 5c862f6ed9 Refactor: Move streaming supervisor methods to `SeekableStreamSupervisor` (#17137) ... The current Supervisor interface is primarily focused on streaming use cases. However, as we introduce supervisors for non-streaming use cases, such as the recently added CompactionSupervisor (and the upcoming BatchSupervisor), certain operations like resetting offsets, checkpointing, task group handoff, etc., are not really applicable to non-streaming use cases. So the methods are split between: 1. Supervisor: common methods that are applicable to both streaming and non-streaming use cases 2. SeekableStreamSupervisor: Supervisor + streaming-only operations. The existing streaming-only overrides exist along with the new abstract method public abstract LagStats computeLagStats(), for which custom implementations already exist in the concrete types This PR is primarily a refactoring change with minimal functional adjustments (e.g., throwing an exception in a few places in SupervisorManager when the supervisor isn't the expected SeekableStreamSupervisor type).		2024-09-24 10:46:37 -07:00
..
src	Refactor: Move streaming supervisor methods to `SeekableStreamSupervisor` (#17137)	2024-09-24 10:46:37 -07:00
pom.xml	Prepare master for 32.0.0 release (#17022)	2024-09-10 11:01:20 +05:30