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

TopologyContext.getTaskToComponent介绍

[英]Gets a map from task id to component id.
[中]获取从任务id到组件id的映射。

代码示例

代码示例来源：origin: alibaba/jstorm

public String toJSONString() {
  Map obj = new HashMap();
  obj.put("task->component", this.getTaskToComponent());
  obj.put("taskid", this.getThisTaskId());
  obj.put("componentid", this.getThisComponentId());

代码示例来源：origin: alibaba/jstorm

public SnapshotState(TopologyContext context, Map<String, Set<Integer>> spouts, Map<String, Set<Integer>> statefulBolts,
    Map<String, Set<Integer>> nonStatefulBolts, Set<Integer> endBolts, ITopologyStateOperator stateOperator) {
  this.context = context;
  this.conf = context.getStormConf();
  this.taskToComponentId = context.getTaskToComponent();
  this.sourceTasks = spouts;
  this.statefulTasks = statefulBolts;
  this.nonStatefulTasks = nonStatefulBolts;
  this.endTasks = endBolts;
  this.lastSuccessfulSnapshot = new BatchStateTracker(TransactionCommon.INIT_BATCH_ID, spouts, statefulBolts, endBolts);
  this.inprogressSnapshots = new RotatingMap<Long, BatchStateTracker>(3, true);
  this.stateOperator = stateOperator;
  this.taskStateInitOperators = new HashMap<String, ITaskStateInitOperator>();
  LOG.info("");
  Map<String, String> taskStateInitOpRegisterMap = ConfigExtension.getTransactionUserTaskInitRegisterMap(conf);
  if (taskStateInitOpRegisterMap != null) {
    for (Entry<String, String> entry : taskStateInitOpRegisterMap.entrySet()) {
      taskStateInitOperators.put(entry.getKey(), (ITaskStateInitOperator) Utils.newInstance(entry.getValue()));
    }
  }
  this.taskSysStateInitOperators = new HashMap<String, ITaskStateInitOperator>();
  Map<String, String> taskSysStateInitOpRegisterMap = ConfigExtension.getTransactionSysTaskInitRegisterMap(conf);
  if (taskSysStateInitOpRegisterMap != null) {
    for (Entry<String, String> entry : taskSysStateInitOpRegisterMap.entrySet()) {
      taskSysStateInitOperators.put(entry.getKey(), (ITaskStateInitOperator) Utils.newInstance(entry.getValue()));
    }
  }
  this.state = State.ACTIVE;
}

代码示例来源：origin: alibaba/mdrill

private TaskSendTargets makeSendTargets() {
  String taskName = TasksCommon.get_readable_name(topologyContext);
  EvenSampler statSample = StormConfig.mk_stats_sampler(stormConf);
  //// ȡǰtaskÿstreamӦЩcommponID,Լη
  // <Stream_id,<component,Grouping>>
  Map<String, Map<String, MkGrouper>> streamComponentGrouper = TasksCommon
      .outbound_components(topologyContext);
  Map<Integer, String> task2Component = topologyContext
      .getTaskToComponent();
  Map<String, List<Integer>> component2Tasks = StormUtils
      .reverse_map(task2Component);
  return new TaskSendTargets(stormConf, taskName, streamComponentGrouper,
      topologyContext, statSample, component2Tasks, taskStats);
}

代码示例来源：origin: com.alibaba.jstorm/jstorm-core

@Override
public String toJSONString() {
  Map obj = new HashMap();
  obj.put("task->component", this.getTaskToComponent());
  obj.put("taskid", this.getThisTaskId());
  obj.put("componentid", this.getThisComponentId());