com.twitter.tormenta

spout

package spout

Visibility
  1. Public
  2. All

Type Members

  1. trait BaseSpout[+T] extends BaseRichSpout with Spout[T]

  2. class FixedTupleSpout extends IRichSpout with CompletableSpout

  3. class FlatMappedSchemeSpout[-T, +U] extends SchemeSpout[U]

    Spout that performs a flatMap operation on its contained SchemeSpout.

  4. class KafkaSpout[+T] extends SchemeSpout[T]

  5. class KestrelSpout[+T] extends SchemeSpout[T]

  6. trait SchemeSpout[+T] extends Spout[T]

  7. trait Spout[+T] extends Serializable

  8. class TraversableSpout[+T] extends Spout[T]

  9. class TwitterSpout[+T] extends BaseRichSpout with Spout[T]

Value Members

  1. object FixedTupleSpout extends

  2. object Spout extends Serializable

    Base trait for Spout implementations.

  3. object TraversableSpout extends Serializable

  4. object TwitterSpout extends Serializable

    Storm Spout implementation for Twitter's streaming API.