|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object backtype.storm.topology.base.BaseComponent backtype.storm.topology.base.BaseRichSpout
public abstract class BaseRichSpout
Constructor Summary | |
---|---|
BaseRichSpout()
|
Method Summary | |
---|---|
void |
ack(java.lang.Object msgId)
Storm 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. |
Methods inherited from class backtype.storm.topology.base.BaseComponent |
---|
getComponentConfiguration |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface backtype.storm.spout.ISpout |
---|
nextTuple, open |
Methods inherited from interface backtype.storm.topology.IComponent |
---|
declareOutputFields, getComponentConfiguration |
Constructor Detail |
---|
public BaseRichSpout()
Method Detail |
---|
public void close()
ISpout
The one context where close is guaranteed to be called is a topology is killed when running Storm in local mode.
close
in interface ISpout
public void activate()
ISpout
activate
in interface ISpout
public void deactivate()
ISpout
deactivate
in interface ISpout
public void ack(java.lang.Object msgId)
ISpout
ack
in interface ISpout
public void fail(java.lang.Object msgId)
ISpout
fail
in interface ISpout
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |