- Use scalainform: twitter#54
- Modifications to Spout code to allow for metric registration: twitter#53
- Fix semantic version (minor API change affected binary compatibiltiy of KafkaSpout)
- Make the forceStartOffset programmable: twitter#51
- Add logging, make storm provided: twitter#47
- Upgrades Avro/Bijection-avro: twitter#49
- Add Scheme "withHandler" Test: twitter#38
- Fixes Implicit resolution in GenericAvroSchemeLaws: twitter#40
- Changed TopologyTest to object from class: twitter#42
- Adds AvroTraversableSpouts for testing Avro Record with SummingBird: twitter#43
- Spout metrics: twitter#46
- Move to sbt 0.13: twitter#45
- Add
tormenta-avromodule: twitter#36
- Break out
tormenta-kestrelandtormenta-kafka: twitter#31 - Add mailing list to README: twitter#34
- Add proper
TraversableSpout(usable within topologies) and first test: twitter#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.