ITaskHook (Storm 2.8.0 API)

All Known Implementing Classes:: BaseTaskHook

public interface ITaskHook

Method Summary

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 Details
- prepare
  
  void prepare(Map<String,Object> conf, TopologyContext context)
- cleanup
  
  void cleanup()
- emit
  
  void emit(EmitInfo info)
- spoutAck
  
  void spoutAck(SpoutAckInfo info)
- spoutFail
  
  void spoutFail(SpoutFailInfo info)
- boltExecute
  
  void boltExecute(BoltExecuteInfo info)
- boltAck
  
  void boltAck(BoltAckInfo info)
- boltFail
  
  void boltFail(BoltFailInfo info)