com.twitter.tormenta.spout

FixedTupleSpout

class FixedTupleSpout extends IRichSpout with CompletableSpout

Source
FixedTupleSpout.java
Linear Supertypes
CompletableSpout, IRichSpout, IComponent, ISpout, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. FixedTupleSpout
  2. CompletableSpout
  3. IRichSpout
  4. IComponent
  5. ISpout
  6. Serializable
  7. AnyRef
  8. Any
Visibility
  1. Public
  2. All

Instance Constructors

  1. new FixedTupleSpout(tuples: java.util.List[_], fieldName: String)

  2. new FixedTupleSpout(tuples: java.util.List[_])

Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

    Definition Classes
    AnyRef → Any
  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  6. def ack(msgId: Any): Unit

    Definition Classes
    FixedTupleSpout → ISpout
  7. def activate(): Unit

    Definition Classes
    FixedTupleSpout → ISpout
  8. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  9. def cleanup(): AnyRef

    Definition Classes
    FixedTupleSpout → CompletableSpout
  10. def clone(): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  11. def close(): Unit

    Definition Classes
    FixedTupleSpout → ISpout
  12. def deactivate(): Unit

    Definition Classes
    FixedTupleSpout → ISpout
  13. def declareOutputFields(declarer: OutputFieldsDeclarer): Unit

    Definition Classes
    FixedTupleSpout → IComponent
  14. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  15. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  16. def exhausted_QMARK_(): AnyRef

    Definition Classes
    FixedTupleSpout → CompletableSpout
  17. def fail(msgId: Any): Unit

    Definition Classes
    FixedTupleSpout → ISpout
  18. def finalize(): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  19. final def getClass(): java.lang.Class[_]

    Definition Classes
    AnyRef → Any
  20. def getCompleted(): Int

  21. def getComponentConfiguration(): Map[String, AnyRef]

    Definition Classes
    FixedTupleSpout → IComponent
  22. def getSourceTuples(): List[FixedTuple]

  23. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  24. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  25. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  26. def nextTuple(): Unit

    Definition Classes
    FixedTupleSpout → ISpout
  27. final def notify(): Unit

    Definition Classes
    AnyRef
  28. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  29. def open(conf: Map, context: TopologyContext, collector: SpoutOutputCollector): Unit

    Definition Classes
    FixedTupleSpout → ISpout
  30. def startup(): AnyRef

    Definition Classes
    FixedTupleSpout → CompletableSpout
  31. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  32. def toString(): String

    Definition Classes
    AnyRef → Any
  33. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()
  34. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()
  35. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()

Inherited from CompletableSpout

Inherited from IRichSpout

Inherited from IComponent

Inherited from ISpout

Inherited from Serializable

Inherited from AnyRef

Inherited from Any