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.