Package org.apache.storm.hooks
Interface ITaskHook
- All Known Implementing Classes:
BaseTaskHook
public interface ITaskHook
-
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)
-
Method Details
-
prepare
-
cleanup
void cleanup() -
emit
-
spoutAck
-
spoutFail
-
boltExecute
-
boltAck
-
boltFail
-