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

TopologyContext.getCodeDir介绍

暂无

代码示例

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

public Number launch(Map<String, Object> conf, TopologyContext context, boolean changeDirectory) {
  ProcessBuilder builder = new ProcessBuilder(command);
  if (!env.isEmpty()) {
    Map<String, String> buildEnv = builder.environment();
    modifyEnvironment(buildEnv);
  }
  if (changeDirectory) {
    builder.directory(new File(context.getCodeDir()));
  }
  ShellLogger = LoggerFactory.getLogger(context.getThisComponentId());
  this.componentName = context.getThisComponentId();
  this.serializer = getSerializer(conf);
  try {
    _subprocess = builder.start();
    processErrorStream = _subprocess.getErrorStream();
    serializer.initialize(_subprocess.getOutputStream(), _subprocess.getInputStream());
    this.pid = serializer.connect(conf, context);
  } catch (IOException e) {
    throw new RuntimeException(
      "Error when launching multilang subprocess\n"
      + getErrorsString(), e);
  } catch (NoOutputException e) {
    throw new RuntimeException(e + getErrorsString() + "\n");
  }
  return this.pid;
}

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

public Number launch(Map conf, TopologyContext context, boolean changeDirectory) {
  ProcessBuilder builder = new ProcessBuilder(command);
  if (!env.isEmpty()) {
    Map<String, String> buildEnv = builder.environment();
    modifyEnvironment(buildEnv);
  }
  if (changeDirectory) {
    builder.directory(new File(context.getCodeDir()));
  }
  ShellLogger = LoggerFactory.getLogger(context.getThisComponentId());
  this.componentName = context.getThisComponentId();
  this.serializer = getSerializer(conf);
  try {
    _subprocess = builder.start();
    processErrorStream = _subprocess.getErrorStream();
    serializer.initialize(_subprocess.getOutputStream(), _subprocess.getInputStream());
    this.pid = serializer.connect(conf, context);
  } catch (IOException e) {
    throw new RuntimeException(
        "Error when launching multilang subprocess\n"
            + getErrorsString(), e);
  } catch (NoOutputException e) {
    throw new RuntimeException(e + getErrorsString() + "\n");
  }
  return this.pid;
}

代码示例来源：origin: hortonworks/streamline

private ShellContext getShellContext(TopologyContext context) {
  ShellContext shellContext = new ShellContext();
  shellContext.setCodeDir(context.getCodeDir());
  shellContext.setPidDir(context.getPIDDir());
  shellContext.setComponentId(context.getThisComponentId());
  return shellContext;
}