[jira] [Created] (SPARK-8975) Implement a mechanism to send a new rate from the driver to the block generator

["Iulian Dragos (JIRA)" <ji...@apache.org>]

Iulian Dragos created SPARK-8975:
------------------------------------

             Summary: Implement a mechanism to send a new rate from the driver to the block generator
                 Key: SPARK-8975
                 URL: https://issues.apache.org/jira/browse/SPARK-8975
             Project: Spark
          Issue Type: Sub-task
          Components: Streaming
            Reporter: Iulian Dragos


Full design doc [here|https://docs.google.com/document/d/1ls_g5fFmfbbSTIfQQpUxH56d0f3OksF567zwA00zK9E/edit?usp=sharing]

- 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.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@spark.apache.org
For additional commands, e-mail: issues-help@spark.apache.org