- Preserve openHook callbacks on SchemeSpouts: #69
- Upgrade to Storm API 1.0.2, as part of this change kestrel support was removed from tormenta: #71
- Update the build: #73
- Support Scala 2.12: #75
- Bumps to upstream versions
- bijection 0.8.0, chill 0.6.0, scala 2.10.5 #65
- Update to scala 2.10 #57
- Scala211 upgrades #58
- Spout to accept a metric registration function #60
- Re-order 3rdparty dependencies #61
- Fix semantic version (minor API change affected binary compatibiltiy of KafkaSpout)
- Make the forceStartOffset programmable: #51
- Add Scheme "withHandler" Test: #38
- Fixes Implicit resolution in GenericAvroSchemeLaws: #40
- Changed TopologyTest to object from class: #42
- Adds AvroTraversableSpouts for testing Avro Record with SummingBird: #43
- Spout metrics: #46
- Move to sbt 0.13: #45
- Add
tormenta-avromodule: #36
- Break out
tormenta-kestrelandtormenta-kafka: #31 - Add mailing list to README: #34
- Add proper
TraversableSpout(usable within topologies) and first test: #35
- Fixed missing
opencall toTwitterSpout - Moved
KafkaSpouttotormenta-kafka - Moved
KestrelSpouttotormenta-kestrel
- tormenta becomes tormenta-core
- Add tormenta-twitter
- Spouts gain map, filter, flatMap
- ScalaSpout -> Spout
- ScalaScheme -> Scheme
- Schemes and Spouts now have proper variance
- More KafkaSpout customization.
- Add ability to customize zkRoot in KafkaSpout.
- Republish using jdk6.
- Remove bijection dependency and
BijectionScheme(This should just be a FunctionScheme anyway.) - Add scala 2.10 cross build
- Added Conjars repo back in. Depend on public version of
bijection.
- Modified
ScalaKryoFactoryfor easier extensions. - Use
bijection-coreinstead ofutil-core
- Added base
ScalaKryoFactoryimplementation.
- Added
ScalaSchemeandScalaSpoutwithchilldependency for serialization.
- Added
ScalaInteropjava class for DRPC.