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

TopologyContext.<init>介绍

暂无

代码示例

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

public TopologyContext make(Integer task_id) {
  TopologyContext rtn=null;
  try {
    String distroot = StormConfig.supervisor_stormdist_root(storm_conf,topologyId);
    String resourcePath = StormConfig.supervisor_storm_resources_path(distroot);
    String workpid = StormConfig.worker_pids_root(storm_conf, worker_id);        
    rtn = new TopologyContext(topology, tasksToComponent, topologyId,
        resourcePath, workpid, task_id);
  } catch (IOException e) {
    LOG.error("UserContextMake make", e);
  }
  return rtn;
}

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

public TopologyContext make(Integer task_id) {
  TopologyContext rtn = null;
  try {
    StormTopology systopology = Common.system_topology(stormConf,topology);
    String distroot = StormConfig.supervisor_stormdist_root(stormConf,topologyId);
    String resourcePath = StormConfig.supervisor_storm_resources_path(distroot);
    String workpid = StormConfig.worker_pids_root(stormConf, workerId);
    rtn = new TopologyContext(systopology, tasksToComponent, topologyId,resourcePath, workpid, task_id);
  } catch (Exception e) {
    LOG.error("SystemContextMake make", e);
  }
  return rtn;
}

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

public TopologyContext makeTopologyContext(StormTopology topology, Integer taskId,
                      clojure.lang.Atom openOrPrepareWasCalled) {
  Map stormConf = new HashMap();
  stormConf.putAll(workerData.getStormConf());
  String topologyId = workerData.getTopologyId();
  HashMap<String, Map<String, Fields>> componentToStreamToFields =
      workerData.generateComponentToStreamToFields(topology);
  return new TopologyContext(topology, stormConf, workerData.getTasksToComponent(),
      workerData.getComponentToSortedTasks(), componentToStreamToFields,
      topologyId, resourcePath, workerId, taskId, workerData.getPort(), workerTasks,
      workerData.getDefaultResources(), workerData.getUserResources(),
      workerData.getExecutorData(), workerData.getRegisteredMetrics(),
      openOrPrepareWasCalled, workerData.getZkCluster());
}

代码示例来源：origin: com.twitter.heron/heron-storm

@Override
@SuppressWarnings("rawtypes")
public void open(Map conf, com.twitter.heron.api.topology.TopologyContext context,
         SpoutOutputCollector collector) {
 topologyContextImpl = new TopologyContext(context);
 spoutOutputCollectorImpl = new SpoutOutputCollectorImpl(collector);
 delegate.open(conf, topologyContextImpl, spoutOutputCollectorImpl);
}

代码示例来源：origin: com.twitter.heron/heron-storm

@Override
public void prepare(com.twitter.heron.api.topology.TopologyContext context,
          String component, String streamId,
          List<Integer> targetTasks) {
 TopologyContext c = new TopologyContext(context);
 GlobalStreamId g = new GlobalStreamId(component, streamId);
 delegate.prepare(c, g, targetTasks);
}

代码示例来源：origin: com.twitter.heron/heron-storm

@Override
@SuppressWarnings("rawtypes")
public void prepare(
  Map conf,
  com.twitter.heron.api.topology.TopologyContext context,
  com.twitter.heron.api.bolt.OutputCollector collector) {
 topologyContextImpl = new TopologyContext(context);
 outputCollectorImpl = new OutputCollectorImpl(collector);
 delegate.prepare(conf, topologyContextImpl, outputCollectorImpl);
}

代码示例来源：origin: com.twitter.heron/heron-storm

@Override
public void prepare(Map<String, Object> newConf,
          com.twitter.heron.api.topology.TopologyContext context) {
 this.conf = newConf;
 if (!newConf.containsKey(Config.STORMCOMPAT_TOPOLOGY_AUTO_TASK_HOOKS)) {
  throw new RuntimeException("StormCompat Translation not done for task hooks");
 }
 List<String> hookClassNames =
   TypeUtils.getListOfStrings(newConf.get(Config.STORMCOMPAT_TOPOLOGY_AUTO_TASK_HOOKS));
 for (String className : hookClassNames) {
  ITaskHook hook;
  try {
   hook = (ITaskHook) Class.forName(className).newInstance();
  } catch (ClassNotFoundException ex) {
   throw new RuntimeException(ex + " ITaskHook class must be in class path.");
  } catch (InstantiationException ex) {
   throw new RuntimeException(ex + " ITaskHook class must be concrete.");
  } catch (IllegalAccessException ex) {
   throw new RuntimeException(ex + " ITaskHook class must have a no-arg constructor.");
  }
  hooks.add(hook);
 }
 // Invoke the prepare() for all ITaskHooks
 TopologyContext ctxt = new TopologyContext(context);
 for (ITaskHook hook : hooks) {
  hook.prepare(newConf, ctxt);
 }
}

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

public TopologyContext makeTopologyContext(StormTopology topology, Integer taskId, clojure.lang.Atom openOrPrepareWasCalled) {
  Map stormConf = workerData.getStormConf();
  String topologyId = workerData.getTopologyId();
  HashMap<String, Map<String, Fields>> componentToStreamToFields = workerData.generateComponentToStreamToFields(topology);
  return new TopologyContext(topology, stormConf, workerData.getTasksToComponent(), workerData.getComponentToSortedTasks(), componentToStreamToFields,
      topologyId, resourcePath, workerId, taskId, workerData.getPort(), workerTasks, workerData.getDefaultResources(), workerData.getUserResources(),
      workerData.getExecutorData(), workerData.getRegisteredMetrics(), openOrPrepareWasCalled, workerData.getZkCluster());
}