Description
Full design doc here
- Add a new message, RateUpdate(newRate: Long) that ReceiverSupervisor handles in its endpoint
- Add a new method to ReceiverTracker
def sendRateUpdate(streamId: Int, newRate: Long): Unit
this method sends an asynchronous RateUpdate message to the receiver supervisor corresponding to streamId - update the rate in the corresponding block generator.
Attachments
Issue Links
- blocks
-
SPARK-8977 Define the RateEstimator interface, and implement the ReceiverRateController
- Resolved
- supercedes
-
SPARK-8834 Throttle DStreams dynamically through back-pressure information
- Closed
- links to