本文整理了Java中org.apache.storm.task.TopologyContext.addTaskHook()方法的一些代码示例，展示了TopologyContext.addTaskHook()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。TopologyContext.addTaskHook()方法的具体详情如下：
包路径：org.apache.storm.task.TopologyContext
类名称：TopologyContext
方法名：addTaskHook

TopologyContext.addTaskHook介绍

暂无

代码示例

代码示例来源：origin: apache/storm

private void addTaskHooks() {
  List<String> hooksClassList = (List<String>) topoConf.get(Config.TOPOLOGY_AUTO_TASK_HOOKS);
  if (null != hooksClassList) {
    for (String hookClass : hooksClassList) {
      try {
        userTopologyContext.addTaskHook(((ITaskHook) Class.forName(hookClass).newInstance()));
      } catch (InstantiationException | IllegalAccessException | ClassNotFoundException e) {
        throw new RuntimeException("Failed to add hook: " + hookClass, e);
      }
    }
  }
}

代码示例来源：origin: apache/storm

@Override
public void prepare(Map<String, Object> topoConf, TopologyContext context, OutputCollector collector) {
  this.collector = collector;
  context.addTaskHook(new BaseTaskHook() {
    @Override
    public void boltExecute(BoltExecuteInfo info) {
      executed++;
    }
    @Override
    public void boltFail(BoltFailInfo info) {
      failed++;
    }
    @Override
    public void boltAck(BoltAckInfo info) {
      acked++;
    }
    @Override
    public void emit(EmitInfo info) {
      emitted++;
    }
    
  });
}