import org.apache.hadoop.test.system.process.RemoteProcess; //导入依赖的package包/类
@Override
protected AbstractDaemonClient createClient(
    RemoteProcess process) throws IOException {
  if (Role.JT.equals(process.getRole())) {
    return createJTClient(process);
  } else if (Role.TT.equals(process.getRole())) {
    return createTTClient(process);
  } else throw new IOException("Role: "+ process.getRole() + "  is not " +
    "applicable to MRCluster");
}
 

import org.apache.hadoop.test.system.process.RemoteProcess; //导入依赖的package包/类
protected void createAllClients() throws IOException {
  for (RemoteProcess p : clusterManager.getAllProcesses()) {
    List<AbstractDaemonClient> dms = daemons.get(p.getRole());
    if (dms == null) {
      dms = new ArrayList<AbstractDaemonClient>();
      daemons.put(p.getRole(), dms);
    }
    dms.add(createClient(p));
  }
}
 

import org.apache.hadoop.test.system.process.RemoteProcess; //导入依赖的package包/类
/**
 * The method is used to only restart one daemon with new config
 * and this gives a great flexibility in choosing which daemon the
 * test wants to restarting instead of changing the config in all the 
 * daemons. 
 * @param client points to the daemon that will restarted.
 * @param configFile the name of the config file
 * @param conf the Configuration object
 * @param role of remote process such as JT,TT,NN,DN
 * @throws IOException thrown in case of any error 
 */
public void restartDaemonWithNewConfig(AbstractDaemonClient client, 
    String configFile, Configuration conf, Enum<?> role) throws IOException {    
  String localDirPath = getHadoopLocalConfDir();
  writeConfToFile(configFile,localDirPath,conf);
  RemoteProcess daemon=clusterManager.getDaemonProcess(client.getHostName(), 
      role);    
  newConfDir = daemon.pushConfig(localDirPath);
  daemon.kill();
  waitForDaemonToStop(client);
  daemon.start(newConfDir);
  waitForDaemonToStart(client);    
  localFolderObj.delete();
}
 

import org.apache.hadoop.test.system.process.RemoteProcess; //导入依赖的package包/类
/**
 * Restart only one daemon as opposed to all the daemons
 * @param client points to the daemon that will restarted. 
 * @param role  of remote process such as JT,TT,NN,DN 
 * @throws IOException is thrown when restart fails
 */
public void restart(AbstractDaemonClient client,Enum<?> role) throws IOException {
  RemoteProcess daemon=clusterManager.getDaemonProcess(client.getHostName(), 
      role);
  daemon.kill();
  waitForDaemonToStop(client);
  daemon.start();
  waitForDaemonToStart(client);
}
 

import org.apache.hadoop.test.system.process.RemoteProcess; //导入依赖的package包/类
@Override
protected AbstractDaemonClient
  createClient(RemoteProcess process) throws IOException {
  Enum<?> pRole = process.getRole();
  if (Role.NN.equals(pRole)) {
    return createNNClient(process);
  } else if (Role.DN.equals(pRole)) {
    return createDNClient(process);
  } else throw new IOException("Role " + pRole +
    " is not supported by HDFSCluster");
}
 

import org.apache.hadoop.test.system.process.RemoteProcess; //导入依赖的package包/类
public MRDaemonClient(Configuration conf, RemoteProcess process)
    throws IOException {
  super(conf, process);
}
 

import org.apache.hadoop.test.system.process.RemoteProcess; //导入依赖的package包/类
public TTClient(Configuration conf, RemoteProcess daemon) 
    throws IOException {
  super(conf, daemon);
}
 

import org.apache.hadoop.test.system.process.RemoteProcess; //导入依赖的package包/类
protected JTClient createJTClient(RemoteProcess jtDaemon)
    throws IOException {
  return new JTClient(getConf(), jtDaemon);
}
 

import org.apache.hadoop.test.system.process.RemoteProcess; //导入依赖的package包/类
protected TTClient createTTClient(RemoteProcess ttDaemon) 
    throws IOException {
  return new TTClient(getConf(), ttDaemon);
}
 

import org.apache.hadoop.test.system.process.RemoteProcess; //导入依赖的package包/类
public HDFSDaemonClient(Configuration conf, RemoteProcess process)
    throws IOException {
  super(conf, process);
}
 

import org.apache.hadoop.test.system.process.RemoteProcess; //导入依赖的package包/类
public DNClient(Configuration conf, RemoteProcess process) throws IOException {
  super(conf, process);
}
 

import org.apache.hadoop.test.system.process.RemoteProcess; //导入依赖的package包/类
protected DNClient createDNClient(RemoteProcess dnDaemon) throws IOException {
  return new DNClient(getConf(), dnDaemon);
}
 

import org.apache.hadoop.test.system.process.RemoteProcess; //导入依赖的package包/类
protected NNClient createNNClient(RemoteProcess nnDaemon) throws IOException {
  return new NNClient(getConf(), nnDaemon);
}
 

import org.apache.hadoop.test.system.process.RemoteProcess; //导入依赖的package包/类
public NNClient(Configuration conf, RemoteProcess process) throws IOException {
  super(conf, process);
}