backtype.storm.hooks

Class ITaskHookDelegate

java.lang.Object

backtype.storm.hooks.ITaskHookDelegate

All Implemented Interfaces:

ITaskHook

public class ITaskHookDelegate
extends java.lang.Object
implements ITaskHook

There would be types of task hooks inside ITaskHookDelegate: 1. task hook's classes specified in config statically. The task hooks' objects would be instantiated by using reflection and added into the list of ITaskHook when the method prepare(Map conf, com.twitter.heron.api.topology.TopologyContext context) is invoked. 2. task hook added dynamically by invoking addHook(ITaskHook)

Constructor Summary

Constructors

Constructor and Description
ITaskHookDelegate()

Method Summary

Modifier and Type	Method and Description
void	addHook(ITaskHook hook)
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
java.util.Map<java.lang.String,java.lang.Object>	getConf()
java.util.List<ITaskHook>	getHooks()
void	prepare(java.util.Map<java.lang.String,java.lang.Object> newConf, 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

ITaskHookDelegate

public ITaskHookDelegate()

Method Detail

addHook

public void addHook(ITaskHook hook)

getHooks

public java.util.List<ITaskHook> getHooks()

getConf

public java.util.Map<java.lang.String,java.lang.Object> getConf()

prepare

public void prepare(java.util.Map<java.lang.String,java.lang.Object> newConf,
                    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