Package org.apache.storm.hooks
Class BaseTaskHook
- java.lang.Object
-
- org.apache.storm.hooks.BaseTaskHook
-
-
Constructor Summary
Constructors Constructor Description BaseTaskHook()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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
public void prepare(Map<String,Object> conf, TopologyContext context)
-
spoutAck
public void spoutAck(SpoutAckInfo info)
-
spoutFail
public void spoutFail(SpoutFailInfo info)
-
boltAck
public void boltAck(BoltAckInfo info)
-
boltFail
public void boltFail(BoltFailInfo info)
-
boltExecute
public void boltExecute(BoltExecuteInfo info)
- Specified by:
boltExecute
in interfaceITaskHook
-
-