Skip to content

Files

Latest commit

Mar 21, 2017
bc2f62e · Mar 21, 2017

History

History
22 lines (15 loc) · 412 Bytes

README.md

File metadata and controls

22 lines (15 loc) · 412 Bytes

Processing RabbitMQ's stream with Apache Spark (Scala implementation)

(Using "sbt" as build tool)
Spark version: 1.6.0
Scala version: 2.10.5

Building & Execution:
sbt package
sbt run

TODO:
1. Logging
2. Refactor the RabbitmqSparkStreamHandler class

spark-submit --class simpl_spark_cassandra.Main target/scala-2.10/rabbitmq_spark_stream_processor_2.10-1.0.jar