public abstract class BaseRichSpout extends BaseComponent implements IRichSpout
Constructor and Description |
---|
BaseRichSpout() |
Modifier and Type | Method and Description |
---|---|
void |
ack(java.lang.Object msgId)
Heron has determined that the tuple emitted by this spout with the msgId identifier
has been fully processed.
|
void |
activate()
Called when a spout has been activated out of a deactivated mode.
|
void |
close()
Called when an ISpout is going to be shutdown.
|
void |
deactivate()
Called when a spout has been deactivated.
|
void |
fail(java.lang.Object msgId)
The tuple emitted by this spout with the msgId identifier has failed to be
fully processed.
|
getComponentConfiguration
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
declareOutputFields, getComponentConfiguration
public void close()
ISpout
The one context where close is guaranteed to be called is a topology is killed when running Heron in local mode.
public void activate()
ISpout
public void deactivate()
ISpout
deactivate
in interface ISpout
public void ack(java.lang.Object msgId)
ISpout
public void fail(java.lang.Object msgId)
ISpout