import backtype.storm.hooks.info.BoltAckInfo; //导入依赖的package包/类
@Override
public void boltAck(BoltAckInfo info) {
  GlobalMetrics.incr("hook_boltAck");
  ++boltAcked;
  if (boltAcked % N == 0) {
    System.out.println("boltAck() is invoked in hook");
    System.out.println(info.ackingTaskId);
    System.out.println(info.processLatencyMs);
    System.out.println(info.tuple);
  }
}
 

import backtype.storm.hooks.info.BoltAckInfo; //导入依赖的package包/类
@Override
public void boltAck(com.twitter.heron.api.hooks.info.BoltAckInfo info) {
  BoltAckInfo ack = new BoltAckInfo(info);
  for (ITaskHook hook : hooks) {
    hook.boltAck(ack);
  }
}
 

import backtype.storm.hooks.info.BoltAckInfo; //导入依赖的package包/类
@Override
public void boltAck(BoltAckInfo info) {
}
 

import backtype.storm.hooks.info.BoltAckInfo; //导入依赖的package包/类
@Override
public void boltAck(BoltAckInfo info) {
	send("BACK", info.ackingTaskId, info.processLatencyMs);
}
 

import backtype.storm.hooks.info.BoltAckInfo; //导入依赖的package包/类
void boltAck(BoltAckInfo info);