backtype.storm.hooks
Class BaseTaskHook
java.lang.Object
backtype.storm.hooks.BaseTaskHook
- All Implemented Interfaces:
- ITaskHook
public class BaseTaskHook
- extends java.lang.Object
- implements ITaskHook
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
BaseTaskHook
public BaseTaskHook()
prepare
public void prepare(java.util.Map conf,
TopologyContext context)
- Specified by:
prepare
in interface ITaskHook
cleanup
public void cleanup()
- Specified by:
cleanup
in interface ITaskHook
emit
public void emit(EmitInfo info)
- Specified by:
emit
in interface ITaskHook
spoutAck
public void spoutAck(SpoutAckInfo info)
- Specified by:
spoutAck
in interface ITaskHook
spoutFail
public void spoutFail(SpoutFailInfo info)
- Specified by:
spoutFail
in interface ITaskHook
boltAck
public void boltAck(BoltAckInfo info)
- Specified by:
boltAck
in interface ITaskHook
boltFail
public void boltFail(BoltFailInfo info)
- Specified by:
boltFail
in interface ITaskHook
error
public void error(java.lang.Throwable error)
- Specified by:
error
in interface ITaskHook