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

Shell.getProcess介绍

[英]get the current sub-process executing the given command
[中]获取执行给定命令的当前子进程

代码示例

代码示例来源：origin: org.apache.hadoop/hadoop-common

/**
 * Static method to destroy all running <code>Shell</code> processes.
 * Iterates through a map of all currently running <code>Shell</code>
 * processes and destroys them one by one. This method is thread safe
 */
public static void destroyAllShellProcesses() {
 synchronized (CHILD_SHELLS) {
  for (Shell shell : CHILD_SHELLS.keySet()) {
   if (shell.getProcess() != null) {
    shell.getProcess().destroy();
   }
  }
  CHILD_SHELLS.clear();
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

@Override
 public void run() {
  Process p = shell.getProcess();
  try {
   p.exitValue();
  } catch (Exception e) {
   //Process has not terminated.
   //So check if it has completed
   //if not just destroy it.
   if (p != null && !shell.completed.get()) {
    shell.setTimedOut();
    p.destroy();
   }
  }
 }
}

代码示例来源：origin: io.hops/hadoop-common

@Override
 public void run() {
  Process p = shell.getProcess();
  try {
   p.exitValue();
  } catch (Exception e) {
   //Process has not terminated.
   //So check if it has completed
   //if not just destroy it.
   if (p != null && !shell.completed.get()) {
    shell.setTimedOut();
    p.destroy();
   }
  }
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-common

@Override
 public void run() {
  Process p = shell.getProcess();
  try {
   p.exitValue();
  } catch (Exception e) {
   //Process has not terminated.
   //So check if it has completed 
   //if not just destroy it.
   if (p != null && !shell.completed.get()) {
    shell.setTimedOut();
    p.destroy();
   }
  }
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

@Override
 public void run() {
  Process p = shell.getProcess();
  try {
   p.exitValue();
  } catch (Exception e) {
   //Process has not terminated.
   //So check if it has completed 
   //if not just destroy it.
   if (p != null && !shell.completed.get()) {
    shell.setTimedOut();
    p.destroy();
   }
  }
 }
}

代码示例来源：origin: com.facebook.hadoop/hadoop-core

@Override
 public void run() {
  Process p = shell.getProcess();
  try {
   p.exitValue();
  } catch (Exception e) {
   //Process has not terminated.
   //So check if it has completed 
   //if not just destroy it.
   if (p != null && !shell.completed.get()) {
    shell.setTimedOut();
    p.destroy();
   }
  }
 }
}

代码示例来源：origin: io.prestosql.hadoop/hadoop-apache

@Override
 public void run() {
  Process p = shell.getProcess();
  try {
   p.exitValue();
  } catch (Exception e) {
   //Process has not terminated.
   //So check if it has completed 
   //if not just destroy it.
   if (p != null && !shell.completed.get()) {
    shell.setTimedOut();
    p.destroy();
   }
  }
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-yarn-server-nodemanager

private void destroyShellProcesses(Set<Shell> shells) {
  for (Shell shell : shells) {
   if(localizingThreads.contains(shell.getWaitingThread())) {
    shell.getProcess().destroy();
   }
  }
 }
}

代码示例来源：origin: cdapio/cdap

@Override
 public void run() {
  Process p = shell.getProcess();
  try {
   p.exitValue();
  } catch (Exception e) {
   //Process has not terminated.
   //So check if it has completed 
   //if not just destroy it.
   if (p != null && !shell.completed.get()) {
    shell.setTimedOut();
    p.destroy();
   }
  }
 }
}