water.H2O.waitForCloudSize()方法的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(3.5k)|赞(0)|评价(0)|浏览(129)

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

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 */);
}

相关文章