Package org.apache.storm.hooks
Class BaseTaskHook
java.lang.Object
org.apache.storm.hooks.BaseTaskHook
- All Implemented Interfaces:
ITaskHook
-
Constructor Summary
Constructors -
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)
-
Constructor Details
-
BaseTaskHook
public BaseTaskHook()
-
-
Method Details
-
prepare
-
cleanup
public void cleanup() -
emit
-
spoutAck
-
spoutFail
-
boltAck
-
boltFail
-
boltExecute
- Specified by:
boltExecutein interfaceITaskHook
-