Package org.apache.storm.hooks
Class BaseTaskHook
java.lang.Object
org.apache.storm.hooks.BaseTaskHook
- All Implemented Interfaces:
ITaskHook
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
boltAck
(BoltAckInfo info) void
boltExecute
(BoltExecuteInfo info) void
boltFail
(BoltFailInfo info) void
cleanup()
void
void
prepare
(Map<String, Object> conf, TopologyContext context) void
spoutAck
(SpoutAckInfo info) void
spoutFail
(SpoutFailInfo info)
-
Constructor Details
-
BaseTaskHook
public BaseTaskHook()
-
-
Method Details
-
prepare
-
cleanup
public void cleanup() -
emit
-
spoutAck
-
spoutFail
-
boltAck
-
boltFail
-
boltExecute
- Specified by:
boltExecute
in interfaceITaskHook
-