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)
// filters out all tuples less than 5:
val filteredScheme: Scheme[Int] = mappedScheme.filter(_ > 5)
// produces lengths for input strings > length of 5
val spout: KafkaSpout[Int] = new KafkaSpout(filteredScheme, zkHost, brokerZkPath, topic, appID, zkRoot)
To use a Spout[T] in a Storm topology, call the getSpout method:
topologyBuilder.setSpout("spoutName", spout.getSpout, 10)
Now you're cooking with gas.
Documentation
To learn more and find links to tutorials and information around the web, check out the Tormenta Wiki.
The latest ScalaDocs are hosted on Tormenta's Github Project Page.
Contact
Discussion occurs primarily on the Tormenta mailing list. Issues should be reported on the GitHub issue tracker.
Get Involved + Code of Conduct
Pull requests and bug reports are always welcome!
We use a lightweight form of project governence inspired by the one used by Apache projects.
Please see Contributing and Committership for our code of conduct and our pull request review process.
The TL;DR is send us a pull request, iterate on the feedback + discussion, and get a +1 from a Committer in order to get your PR accepted.
The current list of active committers (who can +1 a pull request) can be found here: Committers
A list of contributors to the project can be found here: Contributors
Maven
Tormenta modules are available on Maven Central. The current groupid and version for all modules is, respectively, "com.twitter" and 0.12.0.
Current published artifacts are
tormenta-core_2.12tormenta-core_2.11tormenta-core_2.10tormenta-kafka_2.12tormenta-kafka_2.11tormenta-kafka_2.10tormenta-twitter_2.12tormenta-twitter_2.11tormenta-twitter_2.10
The suffix denotes the scala version.
Authors
- Oscar Boykin https://twitter.com/posco
- Sam Ritchie https://twitter.com/sritchie
License
Copyright 2017 Twitter, Inc.
Licensed under the Apache License, Version 2.0.