本文整理了Java中water.H2O.waitForCloudSize()
方法的一些代码示例,展示了H2O.waitForCloudSize()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。H2O.waitForCloudSize()
方法的具体详情如下:
包路径:water.H2O
类名称:H2O
方法名:waitForCloudSize
暂无
代码示例来源:origin: h2oai/h2o-2
public static void waitForCloudSize(int x) {
waitForCloudSize(x, 10000);
}
代码示例来源:origin: h2oai/h2o-2
public static void stall_till_cloudsize(int x, long ms) {
H2O.waitForCloudSize(x, ms);
UKV.put(Job.LIST, new Job.List()); // Jobs.LIST must be part of initial keys
}
}
代码示例来源:origin: h2oai/h2o-2
/** The main method launched in the H2O environment and
* generating documentation.
*/
public static void main(String[] args) throws Exception {
// Boot invoke by default mainClass water.H2O and then call runClass
H2O.waitForCloudSize(1);
createReSTFilesInCwd();
H2O.exit(0);
}
代码示例来源:origin: h2oai/h2o-2
public static void stall_till_cloudsize(int x, long ms) {
H2O.waitForCloudSize(x, ms);
UKV.put(Job.LIST, new Job.List()); // Jobs.LIST must be part of initial keys
}
代码示例来源:origin: h2oai/h2o-2
protected static void startCloud(String[] args, int nnodes) {
for( int i = 1; i < nnodes; i++ ) {
Node n = new NodeVM(args);
n.inheritIO();
n.start();
}
H2O.waitForCloudSize(nnodes);
}
代码示例来源:origin: h2oai/h2o-2
public static void main(String [] args) throws Exception {
System.out.println("Running PCATest");
final int nnodes = 1;
for( int i = 1; i < nnodes; i++ ) {
Node n = new NodeVM(args);
n.inheritIO();
n.start();
}
H2O.waitForCloudSize(nnodes);
System.out.println("Cloud formed");
System.out.println("Running testBasic...");
new PCATest().testBasic();
System.out.println("Running testLinDep...");
new PCATest().testLinDep();
System.out.println("Running testArrests...");
new PCATest().testArrests();
System.out.println("DONE!!!");
}
}
代码示例来源:origin: h2oai/h2o-2
public static void main(String [] args) throws Exception{
System.out.println("Running ParserTest2");
final int nnodes = 1;
for( int i = 1; i < nnodes; i++ ) {
Node n = new NodeVM(args);
n.inheritIO();
n.start();
}
H2O.waitForCloudSize(nnodes);
new ParserTest2 ().runTests();
new ParseTimeTest().runTests();
System.out.println("DONE!");
}
代码示例来源:origin: h2oai/h2o-2
public static void main(String [] args) throws Exception{
System.out.println("Running ParserTest2");
final int nnodes = 1;
for (int i = 0; i < nnodes; i++) {
Node n = new NodeVM(args);
n.inheritIO();
n.start();
}
H2O.waitForCloudSize(nnodes);
System.out.println("Running...");
new CoxPHTest().testCoxPHEfron1Var();
new CoxPHTest().testCoxPHBreslow1Var();
new CoxPHTest().testCoxPHEfron1VarNoStart();
new CoxPHTest().testCoxPHBreslow1VarNoStart();
System.out.println("DONE!");
}
}
代码示例来源:origin: h2oai/h2o-2
public static void main(String [] args) throws Exception{
System.out.println("Running ParserTest2");
final int nnodes = 1;
for( int i = 1; i < nnodes; i++ ) {
Node n = new NodeVM(args);
n.inheritIO();
n.start();
}
H2O.waitForCloudSize(nnodes);
System.out.println("Running...");
new GLMTest2().testGaussianRegression();
new GLMTest2().testPoissonRegression();
new GLMTest2().testGammaRegression();
new GLMTest2().testTweedieRegression();
new GLMTest2().testProstate();
new GLMTest2().testCars();
System.out.println("DONE!");
}
}
代码示例来源:origin: h2oai/h2o-droplets
/** Application Entry Point */
public static void main(String[] args) {
// Run H2O and build a cloud of 1 member
H2OApp.main(args);
H2O.waitForCloudSize(1, 10*1000 /* ms */);
}
}
代码示例来源:origin: h2oai/h2o-droplets
@Before public void initCloud() {
// Setup cloud name
String[] args = new String[] { "-name", "h2o_test_cloud"};
// Build a cloud of 1
H2O.main(args);
H2O.waitForCloudSize(1, 10*1000 /* ms */);
}
内容来源于网络,如有侵权,请联系作者删除!