import backtype.storm.hooks.info.BoltExecuteInfo; //导入依赖的package包/类
@Override
public void boltExecute(BoltExecuteInfo info) {
    if (null != info && null != info.executeLatencyMs && info.executingTaskId == taskId) {
        if (!isMonitoring()) { // if we are within start/endMonitoring, we already have the time
            executionTime.addValue(info.executeLatencyMs);
            checkSend(System.currentTimeMillis());
        }
    }
}
 

import backtype.storm.hooks.info.BoltExecuteInfo; //导入依赖的package包/类
@Override
public void boltExecute(BoltExecuteInfo info) {
  GlobalMetrics.incr("hook_boltExecute");
  ++boltExecuted;
  if (boltExecuted % N == 0) {
    System.out.println("boltExecute() is invoked in hook");
    System.out.println(info.executeLatencyMs);
    System.out.println(info.executingTaskId);
    System.out.println(info.tuple);
  }
}
 

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

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

import backtype.storm.hooks.info.BoltExecuteInfo; //导入依赖的package包/类
@Override
public void boltExecute(BoltExecuteInfo info) {
	send("BEXEC", info.executingTaskId, info.executeLatencyMs);
}
 

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