Package org.apache.storm.hooks
Interface ITaskHook
- All Known Implementing Classes:
BaseTaskHook
public interface ITaskHook
-
Method Summary
Modifier and TypeMethodDescriptionvoidboltAck(BoltAckInfo info) voidboltExecute(BoltExecuteInfo info) voidboltFail(BoltFailInfo info) voidcleanup()voidvoidprepare(Map<String, Object> conf, TopologyContext context) voidspoutAck(SpoutAckInfo info) voidspoutFail(SpoutFailInfo info)
-
Method Details
-
prepare
-
cleanup
void cleanup() -
emit
-
spoutAck
-
spoutFail
-
boltExecute
-
boltAck
-
boltFail
-