I have been trying to implement a CustomReceiverStream using akka actors. I
have a feeder actor which produces messages and a Receiver actor(i give this
to the spark streaming context to get actor stream) which subscribes to the
feeder.
When i create the feeder actor within the scope of the receive
Hi,
I am new to Spark. I have written custom rabbit mq receiver which calls the
store method of Receiver interface. I can see that the block is being
stored. I am trying to process each rdd in the dstream using the foreach
function, but am unable to figure out why this block is not getting invoked
