com.mariussoutier.storm

topology

package topology

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. topology
  2. AnyRef
  3. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Type Members

  1. case class BoltBuilder(boltName: String, bolt: IRichBolt)(implicit topology: TopologyBuilder) extends Product with Serializable

    Prepares bolt declaration.

  2. case class BoltGrouper(boltName: String, declarer: BoltDeclarer) extends BoltGroupings with Product with Serializable

    Contains the declarer and can be used to define groupings on bolts

  3. trait BoltGroupings extends AnyRef

    Defines the grouping methods available on both spouts and bolts.

  4. case class DeclaredSpout(spoutName: String, declarer: SpoutDeclarer) extends BoltGroupings with Product with Serializable

    Contains the declarer and can be used to define groupings on bolts

  5. class SpoutBuilder extends AnyRef

    Prepares spout details.

  6. class StormTopologyDsl extends AnyRef

Value Members

  1. object StormTopologyDsl

  2. def addBolt(bolt: IRichBolt)(implicit dsl: StormTopologyDsl): BoltBuilder

  3. def addBolt(bolt: IRichBolt, optBoltId: Option[String] = None)(implicit dsl: StormTopologyDsl): BoltBuilder

  4. def addBolt(bolt: IBasicBolt, optBoltId: Option[String])(implicit dsl: StormTopologyDsl): BoltBuilder

  5. def addBolt(bolt: IBasicBolt)(implicit dsl: StormTopologyDsl): BoltBuilder

  6. def addSpout(spout: IRichSpout, optSpoutId: Option[String] = None)(implicit dsl: StormTopologyDsl): SpoutBuilder

Inherited from AnyRef

Inherited from Any

Ungrouped