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

TopologyContext.getThisWorkerPort介绍

暂无

代码示例

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

public static String metricName(String name, TopologyContext context) {
  StringBuilder sb = new StringBuilder("storm.topology.");
  sb.append(context.getStormId());
  sb.append(".");
  sb.append(hostName);
  sb.append(".");
  sb.append(dotToUnderScore(context.getThisComponentId()));
  sb.append(".");
  sb.append(context.getThisTaskId());
  sb.append(".");
  sb.append(context.getThisWorkerPort());
  sb.append("-");
  sb.append(name);
  return sb.toString();
}

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

@Override
public void prepare(Map<String, Object> conf, Map<String, Object> arguments, TopologyContext context) {
  String stormId = context.getStormId();
  int port = context.getThisWorkerPort();
  /*
   * Include the topology name & worker port in the file name so that
   * multiple event loggers can log independently.
   */
  String workersArtifactRoot = ConfigUtils.workerArtifactsRoot(conf, stormId, port);
  Path path = Paths.get(workersArtifactRoot, "events.log");
  File dir = path.toFile().getParentFile();
  if (!dir.exists()) {
    dir.mkdirs();
  }
  initLogWriter(path);
  setUpFlushTask();
}

代码示例来源：origin: org.apache.storm/storm-core

public static String metricName(String name, TopologyContext context){
  StringBuilder sb = new StringBuilder("storm.topology.");
  sb.append(context.getStormId());
  sb.append(".");
  sb.append(hostName);
  sb.append(".");
  sb.append(dotToUnderScore(context.getThisComponentId()));
  sb.append(".");
  sb.append(context.getThisTaskId());
  sb.append(".");
  sb.append(context.getThisWorkerPort());
  sb.append("-");
  sb.append(name);
  return sb.toString();
}

代码示例来源：origin: org.apache.storm/storm-core

@Override
public void prepare(Map<String, Object> stormConf, Map<String, Object> arguments, TopologyContext context) {
  String workersArtifactDir; // workers artifact directory
  String stormId = context.getStormId();
  int port = context.getThisWorkerPort();
  if ((workersArtifactDir = (String) stormConf.get(Config.STORM_WORKERS_ARTIFACTS_DIR)) == null) {
    workersArtifactDir = "workers-artifacts";
  }
  /*
   * Include the topology name & worker port in the file name so that
   * multiple event loggers can log independently.
   */
  Path path = Paths.get(workersArtifactDir, stormId, Integer.toString(port), "events.log");
  if (!path.isAbsolute()) {
    path = Paths.get(getLogDir(stormConf), workersArtifactDir,
             stormId, Integer.toString(port), "events.log");
  }
  File dir = path.toFile().getParentFile();
  if (!dir.exists()) {
    dir.mkdirs();
  }
  initLogWriter(path);
  setUpFlushTask();
}

代码示例来源：origin: DigitalPebble/storm-crawler

debugfiletrigger = new File(
    debugfiletriggerpattern.replaceAll("\\{port\\}",
        Integer.toString(context.getThisWorkerPort())));