Java 类org.apache.hadoop.util.Shell.CommandExecutor 实例源码

protected CommandExecutor buildCommandExecutor(String wrapperScriptPath, 
    String containerIdStr, String user, Path pidFile, Resource resource,
    File wordDir, Map<String, String> environment)
        throws IOException {

  String[] command = getRunCommand(wrapperScriptPath,
      containerIdStr, user, pidFile, this.getConf(), resource);

    LOG.info("launchContainer: " + Arrays.toString(command));
    return new ShellCommandExecutor(
        command,
        wordDir,
        environment,
        0L,
        false);
}

@Override
protected CommandExecutor buildCommandExecutor(String wrapperScriptPath,
    String containerIdStr, String userName, Path pidFile, Resource resource,
    File wordDir, Map<String, String> environment) throws IOException {
   return new WintuilsProcessStubExecutor(
       wordDir.toString(),
       containerIdStr, userName, pidFile.toString(), 
       "cmd /c " + wrapperScriptPath);
 }

protected CommandExecutor buildCommandExecutor(String wrapperScriptPath, 
    String containerIdStr, String user, Path pidFile, Resource resource,
    File wordDir, Map<String, String> environment)
        throws IOException {

  String[] command = getRunCommand(wrapperScriptPath,
      containerIdStr, user, pidFile, this.getConf(), resource);

    LOG.info("launchContainer: " + Arrays.toString(command));
    return new ShellCommandExecutor(
        command,
        wordDir,
        environment); 
}

@Override
protected CommandExecutor buildCommandExecutor(String wrapperScriptPath,
    String containerIdStr, String userName, Path pidFile, Resource resource,
    File wordDir, Map<String, String> environment) throws IOException {
   return new WintuilsProcessStubExecutor(
       wordDir.toString(),
       containerIdStr, userName, pidFile.toString(), 
       "cmd /c " + wrapperScriptPath);
 }

protected CommandExecutor buildCommandExecutor(String wrapperScriptPath, 
    String containerIdStr, String user, Path pidFile, Resource resource,
    File wordDir, Map<String, String> environment)
        throws IOException {

  String[] command = getRunCommand(wrapperScriptPath,
      containerIdStr, user, pidFile, this.getConf(), resource);

    LOG.info("launchContainer: " + Arrays.toString(command));
    return new ShellCommandExecutor(
        command,
        wordDir,
        environment); 
}

@Override
protected CommandExecutor buildCommandExecutor(String wrapperScriptPath,
    String containerIdStr, String userName, Path pidFile, Resource resource,
    File wordDir, Map<String, String> environment) throws IOException {
   return new WintuilsProcessStubExecutor(
       wordDir.toString(),
       containerIdStr, userName, pidFile.toString(), 
       "cmd /c " + wrapperScriptPath);
 }

protected CommandExecutor buildCommandExecutor(String wrapperScriptPath, 
    String containerIdStr, String user, Path pidFile, Resource resource,
    File wordDir, Map<String, String> environment)
        throws IOException {

  String[] command = getRunCommand(wrapperScriptPath,
      containerIdStr, user, pidFile, this.getConf(), resource);

    LOG.info("launchContainer: " + Arrays.toString(command));
    return new ShellCommandExecutor(
        command,
        wordDir,
        environment); 
}

@Override
protected CommandExecutor buildCommandExecutor(String wrapperScriptPath, 
    String containerIdStr,
  String userName, Path pidFile,File wordDir, Map<String, String> environment) 
  throws IOException {

  return new WintuilsProcessStubExecutor(
      wordDir.toString(),
      containerIdStr, userName, pidFile.toString(), 
      "cmd /c " + wrapperScriptPath);
}

protected CommandExecutor buildCommandExecutor(String wrapperScriptPath, 
    String containerIdStr, String user, Path pidFile, File wordDir, 
    Map<String, String> environment) 
        throws IOException {

  String[] command = getRunCommand(wrapperScriptPath,
      containerIdStr, user, pidFile, this.getConf());

    LOG.info("launchContainer: " + Arrays.toString(command));
    return new ShellCommandExecutor(
        command,
        wordDir,
        environment); 
}

@Override
protected CommandExecutor buildCommandExecutor(String wrapperScriptPath,
    String containerIdStr, String userName, Path pidFile, Resource resource,
    File wordDir, Map<String, String> environment) throws IOException {
   return new WintuilsProcessStubExecutor(
       wordDir.toString(),
       containerIdStr, userName, pidFile.toString(), 
       "cmd /c " + wrapperScriptPath);
 }