Hi,
There is a RabbitMQ reciver for spark-streaming
http://search.maven.org/#artifactdetails|com.stratio.receiver|rabbitmq|0.1.0-RELEASE|jar
https://github.com/Stratio/RabbitMQ-Receiver
2015-05-12 14:49 GMT+02:00 Dmitry Goldenberg dgoldenberg...@gmail.com:
Thanks, Akhil. It looks like
I found two examples Java version
https://github.com/deepakkashyap/Spark-Streaming-with-RabbitMQ-/blob/master/example/Spark_project/CustomReceiver.java,
and Scala version. https://github.com/d1eg0/spark-streaming-toy
Thanks
Best Regards
On Tue, May 12, 2015 at 2:31 AM, dgoldenberg dgoldenberg
Thanks, Akhil. It looks like in the second example, for Rabbit they're
doing this: https://www.rabbitmq.com/mqtt.html.
On Tue, May 12, 2015 at 7:37 AM, Akhil Das ak...@sigmoidanalytics.com
wrote:
I found two examples Java version
https://github.com/deepakkashyap/Spark-Streaming-with-RabbitMQ
Are there existing or under development versions/modules for streaming
messages out of RabbitMQ with SparkStreaming, or perhaps a RabbitMQ RDD?
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Spark-and-RabbitMQ-tp22852.html
Sent from the Apache Spark User