org.apache.storm.hooks

Interface ITaskHook

All Known Implementing Classes:

BaseTaskHook

public interface ITaskHook

Method Summary

Modifier and Type	Method and 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)