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

YarnTwillRunnerService.prepare介绍

暂无

代码示例

代码示例来源：origin: org.apache.twill/twill-yarn

@Override
public TwillPreparer prepare(TwillRunnable runnable) {
 return prepare(runnable, ResourceSpecification.BASIC);
}

代码示例来源：origin: apache/twill

@Override
public TwillPreparer prepare(TwillRunnable runnable) {
 return prepare(runnable, ResourceSpecification.BASIC);
}

代码示例来源：origin: apache/twill

@Override
public TwillPreparer prepare(TwillRunnable runnable, ResourceSpecification resourceSpecification) {
 return prepare(new SingleRunnableApplication(runnable, resourceSpecification));
}

代码示例来源：origin: org.apache.twill/twill-yarn

@Override
public TwillPreparer prepare(TwillRunnable runnable, ResourceSpecification resourceSpecification) {
 return prepare(new SingleRunnableApplication(runnable, resourceSpecification));
}

代码示例来源：origin: apache/twill

runner.start();
TwillPreparer preparer = runner.prepare(new LogLevelTestApplication());

代码示例来源：origin: apache/twill

TwillController controller = runner.prepare(new LogLevelTestApplication())
 .setLogLevel(LogEntry.Level.DEBUG)
 .addLogHandler(new PrinterLogHandler(new PrintWriter(System.out)))

代码示例来源：origin: apache/twill

@Test
public void testDebugPortOneRunnable() throws Exception {
 YarnTwillRunnerService runner = getTwillRunner();
 runner.start();
 TwillController controller = runner.prepare(new DummyApplication())
                   .enableDebugging("r1")
                   .addLogHandler(new PrinterLogHandler(new PrintWriter(System.out)))
                   .start();
 final CountDownLatch running = new CountDownLatch(1);
 controller.onRunning(new Runnable() {
  @Override
  public void run() {
   running.countDown();
  }
 }, Threads.SAME_THREAD_EXECUTOR);
 Assert.assertTrue(running.await(120, TimeUnit.SECONDS));
 Assert.assertTrue(waitForDebugPort(controller, "r1", 30));
 controller.terminate().get(120, TimeUnit.SECONDS);
 // Sleep a bit before exiting.
 TimeUnit.SECONDS.sleep(2);
}

代码示例来源：origin: apache/twill

@Test
 public void testDebugPortAllRunnables() throws Exception {
  YarnTwillRunnerService runner = getTwillRunner();
  runner.start();

  TwillController controller = runner.prepare(new DummyApplication())
                    .enableDebugging()
                    .addLogHandler(new PrinterLogHandler(new PrintWriter(System.out)))
                    .start();
  final CountDownLatch running = new CountDownLatch(1);
  controller.onRunning(new Runnable() {
   @Override
   public void run() {
    running.countDown();
   }
  }, Threads.SAME_THREAD_EXECUTOR);

  Assert.assertTrue(running.await(120, TimeUnit.SECONDS));
  Assert.assertTrue(waitForDebugPort(controller, "r1", 30));
  Assert.assertTrue(waitForDebugPort(controller, "r2", 30));
  controller.terminate().get(120, TimeUnit.SECONDS);
  // Sleep a bit before exiting.
  TimeUnit.SECONDS.sleep(2);
 }
}

代码示例来源：origin: apache/twill

@Test
public void testRestartSingleRunnable() throws Exception {
 YarnTwillRunnerService runner = getTwillRunner();
 runner.start();
 LOG.info("Starting application {}", SingleRunnableApp.class.getSimpleName());
 TwillController controller = runner.prepare(new SingleRunnableApp())
  .addLogHandler(new PrinterLogHandler(new PrintWriter(System.out)))
  .start();
 // Lets wait until all runnables have started
 waitForInstance(controller, HANGING_RUNNABLE, "002", 120, TimeUnit.SECONDS);
 waitForContainers(controller, 2, 60, TimeUnit.SECONDS);
 // Now restart runnable
 LOG.info("Restarting runnable {}", HANGING_RUNNABLE);
 controller.restartAllInstances(HANGING_RUNNABLE);
 waitForInstance(controller, HANGING_RUNNABLE, "003", 120, TimeUnit.SECONDS);
 waitForContainers(controller, 2, 60, TimeUnit.SECONDS);
 // Send command to HANGING_RUNNABLE to hang when stopped
 controller.sendCommand(HANGING_RUNNABLE, new SleepCommand(1000)).get();
 LOG.info("Restarting runnable {}", HANGING_RUNNABLE);
 controller.restartAllInstances(HANGING_RUNNABLE);
 waitForInstance(controller, HANGING_RUNNABLE, "004", 120, TimeUnit.SECONDS);
 waitForContainers(controller, 2, 60, TimeUnit.SECONDS);
}

代码示例来源：origin: apache/twill

TwillController controller = runner.prepare(new RestartTestApplication())
 .addLogHandler(new PrinterLogHandler(new PrintWriter(System.out)))
 .start();