tormenta icon indicating copy to clipboard operation
tormenta copied to clipboard

Scala extensions for Storm

Results 6 tormenta issues
Sort by recently updated
recently updated
newest added

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.