Package org.apache.storm.hooks
Interface ITaskHook
-
- All Known Implementing Classes:
BaseTaskHook
public interface ITaskHook
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
boltAck(BoltAckInfo info)
void
boltExecute(BoltExecuteInfo info)
void
boltFail(BoltFailInfo info)
void
cleanup()
void
emit(EmitInfo info)
void
prepare(Map<String,Object> conf, TopologyContext context)
void
spoutAck(SpoutAckInfo info)
void
spoutFail(SpoutFailInfo info)
-
-
-
Method Detail
-
prepare
void prepare(Map<String,Object> conf, TopologyContext context)
-
cleanup
void cleanup()
-
emit
void emit(EmitInfo info)
-
spoutAck
void spoutAck(SpoutAckInfo info)
-
spoutFail
void spoutFail(SpoutFailInfo info)
-
boltExecute
void boltExecute(BoltExecuteInfo info)
-
boltAck
void boltAck(BoltAckInfo info)
-
boltFail
void boltFail(BoltFailInfo info)
-
-