com.twitter.heron.api.hooks

Interface ITaskHook

All Known Implementing Classes:

BaseTaskHook

public interface ITaskHook

Method Summary

Methods

Modifier and Type	Method and Description
void	boltAck(BoltAckInfo info) Called in bolt everytime a tuple gets acked
void	boltExecute(BoltExecuteInfo info) Called in bolt everytime a tuple gets executed
void	boltFail(BoltFailInfo info) Called in bolt everytime a tuple gets failed
void	cleanup() Called just before the spout/bolt's cleanup method is called.
void	emit(EmitInfo info) Called everytime a tuple is emitted in spout/bolt
void	prepare(java.util.Map conf, TopologyContext context) Called after the spout/bolt's open/prepare method is called conf is the Config thats passed to the topology
void	spoutAck(SpoutAckInfo info) Called in spout everytime a tuple gets acked
void	spoutFail(SpoutFailInfo info) Called in spout everytime a tuple gets failed

Method Detail

prepare

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

Called after the spout/bolt's open/prepare method is called conf is the Config thats passed to the topology

cleanup

void cleanup()

Called just before the spout/bolt's cleanup method is called.

emit

void emit(EmitInfo info)

Called everytime a tuple is emitted in spout/bolt

spoutAck

void spoutAck(SpoutAckInfo info)

Called in spout everytime a tuple gets acked

spoutFail

void spoutFail(SpoutFailInfo info)

Called in spout everytime a tuple gets failed

boltExecute

void boltExecute(BoltExecuteInfo info)

Called in bolt everytime a tuple gets executed

boltAck

void boltAck(BoltAckInfo info)

Called in bolt everytime a tuple gets acked

boltFail

void boltFail(BoltFailInfo info)

Called in bolt everytime a tuple gets failed