Skip to content

0.3.0
Compare
Choose a tag to compare
@stratiocommit stratiocommit released this 22 Jun 13:21
· 39 commits to master since this release
0.3.0
9478099
  • 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
Assets 2
Loading