tormenta
tormenta copied to clipboard
Scala extensions for Storm
The chill one should suffice with the latest version of storm: https://issues.apache.org/jira/browse/STORM-263 Twitter internally is using a pre-apache classpath blocking us from this upgrade for now.
This can proceed once we find a proper 2.10 build of Kafka to hook in.
Might make sense to fold this code into ScalaStorm and use that from now on.
I want a Spout that approximately every period of time T, `prev + T` and updates `prev = prev + T`.
It should be easy to test bolts and topologies from Scala.
Scalding has a nice auto-generated tuple library that we should use to convert between Storm tuples and Scala tuples.