import backtype.storm.hooks.info.SpoutAckInfo; //导入依赖的package包/类
@Override
public void spoutAck(SpoutAckInfo info) {
  GlobalMetrics.incr("hook_spoutAck");
  ++spoutAcked;
  if (spoutAcked % N == 0) {
    System.out.println("spoutAck() is invoked in hook");
    System.out.println(info.completeLatencyMs);
    System.out.println(info.messageId);
    System.out.println(info.spoutTaskId);
  }
}
 

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

import backtype.storm.hooks.info.SpoutAckInfo; //导入依赖的package包/类
@Override
public void spoutAck(SpoutAckInfo info) {
    MeasurableMsgId streamMsgId = (MeasurableMsgId) info.messageId;
    if (streamMsgId != null && streamMsgId.isSampled()) {
        long cost = System.currentTimeMillis() - streamMsgId.startTime;
        completeMetric.addMetric(streamMsgId.stream, cost);
        if (cost > qos) {
            missMetric.addMetric(streamMsgId.stream, cost);
        }
        if (completeStatMetric != null) {
            completeStatMetric.add(streamMsgId.stream, cost);
        }
    }
}
 

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

import backtype.storm.hooks.info.SpoutAckInfo; //导入依赖的package包/类
@Override
public void spoutAck(SpoutAckInfo info) {
	send("SACK", info.spoutTaskId, info.completeLatencyMs, info.messageId);
}
 

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