本文整理汇总了Java中org.apache.hadoop.test.system.process.RemoteProcess类的典型用法代码示例。如果您正苦于以下问题:Java RemoteProcess类的具体用法?Java RemoteProcess怎么用?Java RemoteProcess使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
RemoteProcess类属于org.apache.hadoop.test.system.process包,在下文中一共展示了RemoteProcess类的14个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: createClient
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");
}
开发者ID:Nextzero,项目名称:hadoop-2.6.0-cdh5.4.3,代码行数:11,代码来源:MRCluster.java
示例2: createAllClients
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));
}
}
开发者ID:Nextzero,项目名称:hadoop-2.6.0-cdh5.4.3,代码行数:11,代码来源:AbstractDaemonCluster.java
示例3: restartDaemonWithNewConfig
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();
}
开发者ID:Nextzero,项目名称:hadoop-2.6.0-cdh5.4.3,代码行数:25,代码来源:AbstractDaemonCluster.java
示例4: restart
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);
}
开发者ID:Nextzero,项目名称:hadoop-2.6.0-cdh5.4.3,代码行数:15,代码来源:AbstractDaemonCluster.java
示例5: createClient
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");
}
开发者ID:Nextzero,项目名称:hadoop-2.6.0-cdh5.4.3,代码行数:12,代码来源:HDFSCluster.java
示例6: MRDaemonClient
import org.apache.hadoop.test.system.process.RemoteProcess; //导入依赖的package包/类
public MRDaemonClient(Configuration conf, RemoteProcess process)
throws IOException {
super(conf, process);
}
开发者ID:Nextzero,项目名称:hadoop-2.6.0-cdh5.4.3,代码行数:5,代码来源:MRDaemonClient.java
示例7: TTClient
import org.apache.hadoop.test.system.process.RemoteProcess; //导入依赖的package包/类
public TTClient(Configuration conf, RemoteProcess daemon)
throws IOException {
super(conf, daemon);
}
开发者ID:Nextzero,项目名称:hadoop-2.6.0-cdh5.4.3,代码行数:5,代码来源:TTClient.java
示例8: createJTClient
import org.apache.hadoop.test.system.process.RemoteProcess; //导入依赖的package包/类
protected JTClient createJTClient(RemoteProcess jtDaemon)
throws IOException {
return new JTClient(getConf(), jtDaemon);
}
开发者ID:Nextzero,项目名称:hadoop-2.6.0-cdh5.4.3,代码行数:5,代码来源:MRCluster.java
示例9: createTTClient
import org.apache.hadoop.test.system.process.RemoteProcess; //导入依赖的package包/类
protected TTClient createTTClient(RemoteProcess ttDaemon)
throws IOException {
return new TTClient(getConf(), ttDaemon);
}
开发者ID:Nextzero,项目名称:hadoop-2.6.0-cdh5.4.3,代码行数:5,代码来源:MRCluster.java
示例10: HDFSDaemonClient
import org.apache.hadoop.test.system.process.RemoteProcess; //导入依赖的package包/类
public HDFSDaemonClient(Configuration conf, RemoteProcess process)
throws IOException {
super(conf, process);
}
开发者ID:Nextzero,项目名称:hadoop-2.6.0-cdh5.4.3,代码行数:5,代码来源:HDFSDaemonClient.java
示例11: DNClient
import org.apache.hadoop.test.system.process.RemoteProcess; //导入依赖的package包/类
public DNClient(Configuration conf, RemoteProcess process) throws IOException {
super(conf, process);
}
开发者ID:Nextzero,项目名称:hadoop-2.6.0-cdh5.4.3,代码行数:4,代码来源:DNClient.java
示例12: createDNClient
import org.apache.hadoop.test.system.process.RemoteProcess; //导入依赖的package包/类
protected DNClient createDNClient(RemoteProcess dnDaemon) throws IOException {
return new DNClient(getConf(), dnDaemon);
}
开发者ID:Nextzero,项目名称:hadoop-2.6.0-cdh5.4.3,代码行数:4,代码来源:HDFSCluster.java
示例13: createNNClient
import org.apache.hadoop.test.system.process.RemoteProcess; //导入依赖的package包/类
protected NNClient createNNClient(RemoteProcess nnDaemon) throws IOException {
return new NNClient(getConf(), nnDaemon);
}
开发者ID:Nextzero,项目名称:hadoop-2.6.0-cdh5.4.3,代码行数:4,代码来源:HDFSCluster.java
示例14: NNClient
import org.apache.hadoop.test.system.process.RemoteProcess; //导入依赖的package包/类
public NNClient(Configuration conf, RemoteProcess process) throws IOException {
super(conf, process);
}
开发者ID:Nextzero,项目名称:hadoop-2.6.0-cdh5.4.3,代码行数:4,代码来源:NNClient.java
注:本文中的org.apache.hadoop.test.system.process.RemoteProcess类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论