com.twitter.tormenta.spout

FixedTupleSpout

object FixedTupleSpout extends

Source
FixedTupleSpout.java
Visibility
  1. Public
  2. All

Value Members

  1. def clear(stormId: String): Unit

  2. def getNumAcked(stormId: String): Int

  3. def getNumFailed(stormId: String): Int