twitter/tormenta

This is stars and forks stats for /twitter/tormenta repository. As of 24 Apr, 2024 this repository has 132 stars and 41 forks.

Tormenta Scala extensions for the Storm distributed computation system. Tormenta adds a type-safe wrapper over Storm's Kafka spout. This type safety allows the user to push mapping and filtering transformations down to the level of the spout itself: import com.twitter.tormenta.scheme._ import com.twitter.tormenta.spout._ // produces strings: val scheme: Scheme[String] = Scheme { bytes => Some(new String(bytes)) } // produces integers w/ string length: val mappedScheme: Scheme[Int] = scheme.map(_.length) //...