com.twitter.tormenta.spout
Spout that performs a flatMap operation on its contained SchemeSpout. Used to implement map, filter and flatMap on SchemeSpout.
This is the only required override.
Spout that performs a flatMap operation on its contained SchemeSpout. Used to implement map, filter and flatMap on SchemeSpout.