backtype.storm.hooks
Interface ITaskHook

All Known Implementing Classes:

BaseTaskHook

public interface ITaskHook

Method Summary

void	boltAck(BoltAckInfo info)
void	boltFail(BoltFailInfo info)
void	cleanup()
void	emit(EmitInfo info)
void	prepare(java.util.Map conf, TopologyContext context)
void	spoutAck(SpoutAckInfo info)
void	spoutFail(SpoutFailInfo info)

Method Detail

prepare

void prepare(java.util.Map conf,
             TopologyContext context)

cleanup

void cleanup()

emit

void emit(EmitInfo info)

spoutAck

void spoutAck(SpoutAckInfo info)

spoutFail

void spoutFail(SpoutFailInfo info)

boltAck

void boltAck(BoltAckInfo info)

boltFail

void boltFail(BoltFailInfo info)