This repository was archived by the owner on Oct 15, 2025. It is now read-only.
Tags: Stratio/spark-rabbitmq
Tags
* Compatibility for Spark version 1.6.1 * Bug fixing * Distributed RabbitMQ consumer with direct approach * Parallelize the consumption in one node, to have more than one consumer * Encapsulated consumer and pool of consumers * Optimized RabbitMQRDD functions in order to have better performance * RabbitMQ messages can be typed * Integration tests added for Scala implementation * Java examples and refactor rabbitMQUtils
* Compatibility for Spark version 1.6.1 * Bug fixing * Distributed RabbitMQ consumer with direct approach * Parallelize the consumption in one node, to have more than one consumer * Encapsulated consumer and pool of consumers * Optimized RabbitMQRDD functions in order to have better performance * RabbitMQ messages can be typed * Integration tests added for Scala implementation * Java examples and refactor rabbitMQUtils
* Compatibility for Spark version 1.6.1 * Bug fixing * Distributed RabbitMQ consumer with direct approach * Parallelize the consumption in one node, to have more than one consumer * Encapsulated consumer and pool of consumers * Optimized functions of RabbitMQRDD in order to have better performance * RabbitMQ messages can be typed