com.twitter.heron.api.hooks

Class BaseTaskHook

java.lang.Object

com.twitter.heron.api.hooks.BaseTaskHook

All Implemented Interfaces:

ITaskHook

public class BaseTaskHook
extends java.lang.Object
implements ITaskHook

Constructor Summary

Constructors

Constructor and Description
BaseTaskHook()

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BaseTaskHook

public BaseTaskHook()

Method Detail

prepare

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

Description copied from interface: ITaskHook

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

Specified by:

prepare in interface ITaskHook

cleanup

public void cleanup()

Description copied from interface: ITaskHook

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

Specified by:

cleanup in interface ITaskHook

emit

public void emit(EmitInfo info)

Description copied from interface: ITaskHook

Called everytime a tuple is emitted in spout/bolt

Specified by:

emit in interface ITaskHook

spoutAck

public void spoutAck(SpoutAckInfo info)

Description copied from interface: ITaskHook

Called in spout everytime a tuple gets acked

Specified by:

spoutAck in interface ITaskHook

spoutFail

public void spoutFail(SpoutFailInfo info)

Description copied from interface: ITaskHook

Called in spout everytime a tuple gets failed

Specified by:

spoutFail in interface ITaskHook

boltAck

public void boltAck(BoltAckInfo info)

Description copied from interface: ITaskHook

Called in bolt everytime a tuple gets acked

Specified by:

boltAck in interface ITaskHook

boltFail

public void boltFail(BoltFailInfo info)

Description copied from interface: ITaskHook

Called in bolt everytime a tuple gets failed

Specified by:

boltFail in interface ITaskHook

boltExecute

public void boltExecute(BoltExecuteInfo info)

Description copied from interface: ITaskHook

Called in bolt everytime a tuple gets executed

Specified by:

boltExecute in interface ITaskHook