0.3.0-RC2
stratiocommit
released this
22 Jun 11:19
·
39 commits
to master
since this release
- 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