Releases: Stratio/spark-rabbitmq
Releases · Stratio/spark-rabbitmq
0.5.1
0.5.0-RC1
- Upgrade to Spark 2.0
- Optimized accumulators with AccumulatorV2 API
- Removed crossbuild with Spark 1.6 and 1.5
0.5.0
- Upgrade to Spark 2.0
- Optimized accumulators with AccumulatorV2 API
- Removed crossbuild with Spark 1.6 and 1.5
0.4.0-RC1
- Upgrade scala version to 2.11.8
- Upgrade to rabbitMQ library version 3.6.6
- Removed Array[Byte] in createStream API
- The library now run with Delivery message of RabbitMQ
- Added tests with Delivery message option
- Bugfix: Send noAck when store messages fails
- Bugfix: Integer conversion in message parameters
- Bugfix: Close connections correctly
0.4.0
- Upgrade scala version to 2.11.8
- Upgrade to rabbitMQ library version 3.6.6
- Removed Array[Byte] in createStream API
- The library now run with Delivery message of RabbitMQ
- Added tests with Delivery message option
- Bugfix: Send noAck when store messages fails
- Bugfix: Integer conversion in message parameters
- Bugfix: Close connections correctly
0.3.0-RC2
- 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
0.3.0
- 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
0.3.0-RC1
- 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
0.2.0-RC1
- Compatibility for Spark versions 1.4 and 1.5
- Bug fixing
0.2.0
- Compatibility for Spark versions 1.4 and 1.5
- Bug fixing