org.renci.common.exec.Executor.execute()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(16.5k)|赞(0)|评价(0)|浏览(210)

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

Executor.execute介绍

[英]run the command
[中]运行命令

代码示例

代码示例来源:origin: edu.unc.mapseq/modules

@Override
public ModuleOutput call() throws Exception {
  logger.debug("ENTERING call()");
  Properties readLengthProperties = new Properties();
  FileInputStream fis = new FileInputStream(this.readLength);
  readLengthProperties.loadFromXML(fis);
  fis.close();
  StringBuilder command = new StringBuilder(getExecutable());
  command.append(" ").append(junction.getAbsolutePath());
  command.append(" ").append(readLengthProperties.getProperty("maxLength"));
  command.append(" ").append(minimumAnchor.toString());
  command.append(" ").append(referenceSequenceDirectory.getAbsolutePath());
  command.append(" ").append(sam.getAbsolutePath());
  CommandInput commandInput = new CommandInput();
  logger.info("command.toString(): {}", command.toString());
  commandInput.setCommand(command.toString());
  CommandOutput commandOutput;
  try {
    Executor executor = BashExecutor.getInstance();
    commandOutput = executor.execute(commandInput, new File(System.getProperty("user.home"), ".mapseqrc"));
  } catch (ExecutorException e) {
    throw new ModuleException(e);
  }
  return new ShellModuleOutput(commandOutput);
}

代码示例来源:origin: edu.unc.mapseq/modules

@Override
public ModuleOutput call() throws Exception {
  logger.debug("ENTERING call()");
  StringBuilder command = new StringBuilder(getExecutable());
  command.append(" ").append(input.getAbsolutePath());
  command.append(" ").append(outputDirectory.getAbsolutePath());
  if (this.outputDirectory.isDirectory() && !this.outputDirectory.getAbsolutePath().endsWith("/")) {
    command.append("/");
  }
  CommandInput commandInput = new CommandInput();
  logger.info("command.toString(): {}", command.toString());
  commandInput.setCommand(command.toString());
  CommandOutput commandOutput;
  try {
    Executor executor = BashExecutor.getInstance();
    commandOutput = executor.execute(commandInput, new File(System.getProperty("user.home"), ".mapseqrc"));
  } catch (ExecutorException e) {
    throw new ModuleException(e);
  }
  return new ShellModuleOutput(commandOutput);
}

代码示例来源:origin: edu.unc.mapseq/modules

@Override
public ModuleOutput call() throws ModuleException {
  CommandInput commandInput = new CommandInput();
  StringBuilder command = new StringBuilder();
  command.append(getModuleClass().getAnnotation(Executable.class).value());
  command.append(" ").append(inFile.getAbsolutePath());
  command.append(" ").append(outFile.getAbsolutePath());
  command.append(" ").append(transcriptDB.getAbsolutePath());
  command.append(" ").append(sqHeader.getAbsolutePath());
  commandInput.setCommand(command.toString());
  CommandOutput commandOutput;
  try {
    Executor executor = BashExecutor.getInstance();
    commandOutput = executor.execute(commandInput, new File(System.getProperty("user.home"), ".mapseqrc"));
  } catch (ExecutorException e) {
    throw new ModuleException(e);
  }
  return new ShellModuleOutput(commandOutput);
}

代码示例来源:origin: edu.unc.mapseq/modules

@Override
public ModuleOutput call() throws Exception {
  logger.debug("ENTERING call()");
  StringBuilder command = new StringBuilder(getExecutable());
  command.append(" ").append(this.minimumAnchorWidth.toString());
  command.append(" ").append(this.maximumAnchor.toString());
  command.append(" ").append(this.maximumThresholdEach.toString());
  command.append(" ").append(this.maximumThresholdTotal.toString());
  command.append(" ").append(this.junction.getAbsolutePath());
  command.append(" 1");
  command.append(" ").append(this.fusionJunction.getAbsolutePath());
  command.append(" 1");
  command.append(" ").append(this.referenceSequenceDirectory.getAbsolutePath());
  if (this.referenceSequenceDirectory.isDirectory()
      && !this.referenceSequenceDirectory.getAbsolutePath().endsWith("/")) {
    command.append("/");
  }
  command.append(" ").append(this.output.getAbsolutePath());
  CommandInput commandInput = new CommandInput();
  logger.info("command.toString(): {}", command.toString());
  commandInput.setCommand(command.toString());
  CommandOutput commandOutput;
  try {
    Executor executor = BashExecutor.getInstance();
    commandOutput = executor.execute(commandInput, new File(System.getProperty("user.home"), ".mapseqrc"));
  } catch (ExecutorException e) {
    throw new ModuleException(e);
  }
  return new ShellModuleOutput(commandOutput);
}

代码示例来源:origin: edu.unc.mapseq/modules

@Override
public ModuleOutput call() throws Exception {
  logger.debug("ENTERING call()");
  StringBuilder command = new StringBuilder(getExecutable());
  command.append(" ").append(this.minimumAnchor.toString());
  command.append(" ").append(this.maximumAnchor.toString());
  command.append(" ").append(this.maximumSequenceThreshold.toString());
  command.append(" ").append(this.junction.getAbsolutePath());
  command.append(" ").append(this.referenceSequenceDirectory.getAbsolutePath());
  if (this.referenceSequenceDirectory.isDirectory()
      && !this.referenceSequenceDirectory.getAbsolutePath().endsWith("/")) {
    command.append("/");
  }
  command.append(" ").append(this.output.getAbsolutePath());
  CommandInput commandInput = new CommandInput();
  logger.info("command.toString(): {}", command.toString());
  commandInput.setCommand(command.toString());
  CommandOutput commandOutput;
  try {
    Executor executor = BashExecutor.getInstance();
    commandOutput = executor.execute(commandInput, new File(System.getProperty("user.home"), ".mapseqrc"));
  } catch (ExecutorException e) {
    throw new ModuleException(e);
  }
  return new ShellModuleOutput(commandOutput);
}

代码示例来源:origin: edu.unc.mapseq/modules

@Override
public ModuleOutput call() throws Exception {
  CommandInput commandInput = new CommandInput();
  StringBuilder command = new StringBuilder();
  command.append(getModuleClass().getAnnotation(Executable.class).value());
  command.append(" -c ").append(column.toString());
  command.append(" -q ").append(quantile.toString());
  command.append(" -t ").append(target.toString());
  command.append(" -o ").append(output.getAbsolutePath());
  command.append(" ").append(input.getAbsolutePath());
  commandInput.setCommand(command.toString());
  CommandOutput commandOutput;
  try {
    Executor executor = BashExecutor.getInstance();
    commandOutput = executor.execute(commandInput, new File(System.getProperty("user.home"), ".mapseqrc"));
  } catch (ExecutorException e) {
    throw new ModuleException(e);
  }
  return new ShellModuleOutput(commandOutput);
}

代码示例来源:origin: edu.unc.mapseq/modules

@Override
public ModuleOutput call() throws Exception {
  logger.debug("ENTERING call()");
  StringBuilder command = new StringBuilder(getExecutable());
  command.append(" ").append(clusterDirectory.getAbsolutePath()).append("/");
  CommandInput commandInput = new CommandInput();
  logger.info("command.toString(): {}", command.toString());
  commandInput.setCommand(command.toString());
  CommandOutput commandOutput;
  try {
    Executor executor = BashExecutor.getInstance();
    commandOutput = executor.execute(commandInput, new File(System.getProperty("user.home"), ".mapseqrc"));
  } catch (ExecutorException e) {
    throw new ModuleException(e);
  }
  return new ShellModuleOutput(commandOutput);
}

代码示例来源:origin: edu.unc.mapseq/modules

@Override
public ModuleOutput call() throws Exception {
  CommandInput commandInput = new CommandInput();
  StringBuilder commandSB = new StringBuilder();
  commandSB.append(this.executable);
  if (argument != null) {
    for (String arg : argument) {
      commandSB.append(String.format(" %s", arg));
    }
  }
  commandInput.setCommand(commandSB.toString());
  CommandOutput commandOutput;
  try {
    Executor executor = BashExecutor.getInstance();
    commandOutput = executor.execute(commandInput, new File(System.getProperty("user.home"), ".mapseqrc"));
  } catch (ExecutorException e) {
    throw new ModuleException(e);
  }
  return new ShellModuleOutput(commandOutput);
}

代码示例来源:origin: edu.unc.mapseq/modules

@Override
public ModuleOutput call() throws Exception {
  logger.debug("ENTERING call()");
  StringBuilder command = new StringBuilder(getExecutable());
  command.append(" ").append(output.getAbsolutePath());
  if (fastq) {
    command.append(" 1");
  }
  command.append(" ").append(input.getAbsolutePath());
  CommandInput commandInput = new CommandInput();
  logger.info("command.toString(): {}", command.toString());
  commandInput.setCommand(command.toString());
  CommandOutput commandOutput;
  try {
    Executor executor = BashExecutor.getInstance();
    commandOutput = executor.execute(commandInput, new File(System.getProperty("user.home"), ".mapseqrc"));
  } catch (ExecutorException e) {
    throw new ModuleException(e);
  }
  return new ShellModuleOutput(commandOutput);
}

代码示例来源:origin: edu.unc.mapseq/modules

@Override
public ModuleOutput call() throws ModuleException {
  File userHome = new File(System.getProperty("user.home"));
  CommandInput commandInput = new CommandInput();
  StringBuilder command = new StringBuilder();
  command.append(String.format(getModuleClass().getAnnotation(Executable.class).value()));
  commandInput.setCommand(command.toString());
  CommandOutput commandOutput;
  try {
    Executor executor = BashExecutor.getInstance();
    commandOutput = executor.execute(commandInput, new File(userHome, ".mapseqrc"));
  } catch (ExecutorException e) {
    throw new ModuleException(e);
  }
  return new ShellModuleOutput(commandOutput);
}

代码示例来源:origin: edu.unc.mapseq/modules

@Override
public ModuleOutput call() throws ModuleException {
  CommandOutput commandOutput = null;
  try {
    StringBuilder command = new StringBuilder();
    command.append("/bin/ln -s ").append(fastaDB).append(" ").append(symlinkFile.getAbsolutePath()).append(";");
    command.append(String.format("$%s_%s", getWorkflowName().toUpperCase(),
        getModuleClass().getAnnotation(Executable.class).value()));
    command.append(" ")
        .append(getModuleClass().getDeclaredField("algorithm").getAnnotation(InputArgument.class).flag())
        .append(" ").append(algorithm.getValue());
    command.append(" ").append(symlinkFile.getAbsolutePath());
    CommandInput commandInput = new CommandInput();
    File mapseqTmpDir = new File(System.getenv("MAPSEQ_HOME"), "tmp");
    commandInput.setWorkDir(mapseqTmpDir);
    commandInput.setCommand(command.toString());
    Executor executor = BashExecutor.getInstance();
    commandOutput = executor.execute(commandInput, new File(System.getProperty("user.home"), ".mapseqrc"));
  } catch (Exception e) {
    throw new ModuleException(e);
  }
  return new ShellModuleOutput(commandOutput);
}

代码示例来源:origin: edu.unc.mapseq/modules

@Override
public ModuleOutput call() throws ModuleException {
  CommandInput commandInput = new CommandInput();
  commandInput.setCommand(String.format(getModuleClass().getAnnotation(Executable.class).value(),
      getWorkflowName().toUpperCase(), input.getAbsolutePath(), output.getAbsolutePath()));
  CommandOutput commandOutput;
  try {
    Executor executor = BashExecutor.getInstance();
    commandOutput = executor.execute(commandInput, new File(System.getProperty("user.home"), ".mapseqrc"));
  } catch (ExecutorException e) {
    throw new ModuleException(e);
  }
  return new ShellModuleOutput(commandOutput);
}

代码示例来源:origin: edu.unc.mapseq/modules

@Override
public ModuleOutput call() throws Exception {
  CommandInput commandInput = new CommandInput();
  commandInput.setCommand(String.format(getModuleClass().getAnnotation(Executable.class).value(),
      geneResults.getAbsolutePath(), origGeneResults.getAbsolutePath()));
  CommandOutput commandOutput;
  try {
    Executor executor = BashExecutor.getInstance();
    commandOutput = executor.execute(commandInput, new File(System.getProperty("user.home"), ".mapseqrc"));
  } catch (ExecutorException e) {
    throw new ModuleException(e);
  }
  return new ShellModuleOutput(commandOutput);
}

代码示例来源:origin: edu.unc.mapseq.mapseq-modules/mapseq-module-samtools

@Override
public ModuleOutput call() throws ModuleException {
  CommandInput commandInput = new CommandInput();
  commandInput.setCommand(String.format(getModuleClass().getAnnotation(Executable.class).value(),
      getWorkflowName().toUpperCase(), input.getAbsolutePath(), output.getAbsolutePath()));
  CommandOutput commandOutput;
  try {
    Executor executor = BashExecutor.getInstance();
    commandOutput = executor.execute(commandInput, new File(System.getProperty("user.home"), ".mapseqrc"));
  } catch (ExecutorException e) {
    throw new ModuleException(e);
  }
  return new ShellModuleOutput(commandOutput);
}

代码示例来源:origin: edu.unc.mapseq/modules

@Override
public ModuleOutput call() throws ModuleException {
  CommandInput commandInput = new CommandInput();
  StringBuilder command = new StringBuilder();
  command.append(getModuleClass().getAnnotation(Executable.class).value());
  try {
    command.append(output.getAbsolutePath());
    for (File f : entry) {
      command.append(" ").append(f.getAbsolutePath());
    }
  } catch (Exception e) {
    throw new ModuleException(e);
  }
  commandInput.setCommand(command.toString());
  CommandOutput commandOutput;
  try {
    Executor executor = BashExecutor.getInstance();
    commandOutput = executor.execute(commandInput, new File(System.getProperty("user.home"), ".mapseqrc"));
  } catch (ExecutorException e) {
    throw new ModuleException(e);
  }
  return new ShellModuleOutput(commandOutput);
}

代码示例来源:origin: edu.unc.mapseq/modules

@Override
public ModuleOutput call() throws Exception {
  CommandInput commandInput = new CommandInput();
  StringBuilder command = new StringBuilder();
  command.append(getModuleClass().getAnnotation(Executable.class).value());
  command.append(" ").append(input.getAbsolutePath()).append(" ").append(output.getAbsolutePath());
  commandInput.setCommand(command.toString());
  CommandOutput commandOutput;
  try {
    Executor executor = BashExecutor.getInstance();
    commandOutput = executor.execute(commandInput, new File(System.getProperty("user.home"), ".mapseqrc"));
  } catch (ExecutorException e) {
    throw new ModuleException(e);
  }
  FileData fileData = new FileData();
  fileData.setMimeType(MimeType.APPLICATION_PDF);
  fileData.setName(output.getName());
  addFileData(fileData);
  return new ShellModuleOutput(commandOutput);
}

代码示例来源:origin: edu.unc.mapseq/modules

@Override
public ModuleOutput call() throws ModuleException {
  CommandInput commandInput = new CommandInput();
  commandInput.setCommand(String.format(getModuleClass().getAnnotation(Executable.class).value(),
      flagstatInput.getAbsolutePath(), output.getAbsolutePath()));
  CommandOutput commandOutput;
  try {
    Executor executor = BashExecutor.getInstance();
    commandOutput = executor.execute(commandInput);
  } catch (ExecutorException e) {
    throw new ModuleException(e);
  }
  return new ShellModuleOutput(commandOutput);
}

代码示例来源:origin: edu.unc.mapseq.mapseq-modules/mapseq-module-samtools

@Override
public ModuleOutput call() throws ModuleException {
  CommandInput commandInput = new CommandInput();
  commandInput.setCommand(String.format(getModuleClass().getAnnotation(Executable.class).value(),
      flagstatInput.getAbsolutePath(), output.getAbsolutePath()));
  CommandOutput commandOutput;
  try {
    Executor executor = BashExecutor.getInstance();
    commandOutput = executor.execute(commandInput);
  } catch (ExecutorException e) {
    throw new ModuleException(e);
  }
  return new ShellModuleOutput(commandOutput);
}

代码示例来源:origin: edu.unc.mapseq/modules

@Override
public ModuleOutput call() throws ModuleException {
  logger.debug("ENTERING call()");
  CommandOutput commandOutput;
  try {
    StringBuilder command = new StringBuilder();
    command.append(getModuleClass().getAnnotation(Executable.class).value());
    command.append(" ").append(regularExpression);
    command.append(" > ").append(outputFile.getAbsolutePath());
    CommandInput commandInput = new CommandInput();
    commandInput.setWorkDir(directory);
    commandInput.setCommand(command.toString());
    Executor executor = BashExecutor.getInstance();
    commandOutput = executor.execute(commandInput, new File(System.getProperty("user.home"), ".mapseqrc"));
    if (mimeType != null) {
      FileData fileData = new FileData();
      fileData.setName(outputFile.getName());
      fileData.setMimeType(mimeType);
      addFileData(fileData);
    }
  } catch (ExecutorException e) {
    throw new ModuleException(e);
  }
  return new ShellModuleOutput(commandOutput);
}

代码示例来源:origin: org.renci.launchers/launcher-core

public void run() {
  for (LaunchDescriptorBean ldb : getLaunchDescriptorBeans()) {
    String command = ldb.getCommands().get(0);
    logger.debug("command = " + command);
    Executor sh = new Executor(command);
    sh.setEnvironment(new HashMap<String, String>());
    sh.setWorkDir(getWorkDirectory());
    try {
      sh.execute();
    } catch (ExecutorException e) {
      logger.error("Execution error: " + e.getMessage());
    }
    setStdOut(sh.getStdout());
    setStdErr(sh.getStderr());
    setExitCode(sh.getExitCode());
  }
}

相关文章