| Message view | « Date » · « Thread » |
|---|---|
| Top | « Date » · « Thread » |
| From | Xi Shen <davidshe...@gmail.com> |
| Subject | How to implement a InputDStream like the twitter stream in Spark? |
| Date | Wed, 17 Aug 2016 09:39:13 GMT |
Hi, First I am not sure if I should inherit from InputDStream, or ReceiverInputDStream. For ReceiverInputDStream, why would I want to run a receiver on each worker nodes? If I want to inherit InputDStream, what should I do in the comput() method? -- Thanks, David S. | |
| Mime |
|
| View raw message | |