| Package | Description |
|---|---|
| org.apache.reef.client |
Client APIs for REEF.
|
| org.apache.reef.examples.hello |
The Hello REEF example.
|
| org.apache.reef.examples.helloCLR |
The Hello REEF example for the CLR.
|
| org.apache.reef.examples.hellohttp | |
| org.apache.reef.tests | |
| org.apache.reef.tests.fail.driver | |
| org.apache.reef.tests.fail.task | |
| org.apache.reef.tests.messaging.driver | |
| org.apache.reef.tests.yarn.failure |
| Modifier and Type | Field and Description |
|---|---|
static LauncherStatus |
LauncherStatus.COMPLETED |
static LauncherStatus |
LauncherStatus.FAILED |
static LauncherStatus |
LauncherStatus.FORCE_CLOSED |
static LauncherStatus |
LauncherStatus.INIT |
static LauncherStatus |
LauncherStatus.RUNNING |
| Modifier and Type | Method and Description |
|---|---|
static LauncherStatus |
LauncherStatus.FAILED(Optional<Throwable> ex) |
static LauncherStatus |
LauncherStatus.FAILED(Throwable ex) |
LauncherStatus |
DriverLauncher.getStatus() |
LauncherStatus |
DriverLauncher.run(Configuration driverConfig)
Run a job.
|
LauncherStatus |
DriverLauncher.run(Configuration driverConfig,
long timeOut)
Run a job with a waiting timeout after which it will be killed, if it did not complete yet.
|
| Modifier and Type | Method and Description |
|---|---|
void |
DriverLauncher.setStatusAndNotify(LauncherStatus status)
Update job status and notify the waiting thread.
|
| Modifier and Type | Method and Description |
|---|---|
static LauncherStatus |
HelloREEF.runHelloReef(Configuration runtimeConf,
int timeOut) |
| Modifier and Type | Method and Description |
|---|---|
static LauncherStatus |
HelloCLR.runHelloCLR(Configuration runtimeConf,
int timeOut,
File clrFolder) |
| Modifier and Type | Method and Description |
|---|---|
static LauncherStatus |
HelloREEFHttp.runHelloReef(Configuration runtimeConf,
int timeOut)
Run Hello Reef with merged configuration
|
| Modifier and Type | Method and Description |
|---|---|
LauncherStatus |
TestDriverLauncher.run(Configuration driverConfig)
Run a job.
|
LauncherStatus |
TestDriverLauncher.run(Configuration driverConfig,
long timeOut)
Run a job with a waiting timeout after which it will be killed, if it did not complete yet.
|
| Modifier and Type | Method and Description |
|---|---|
static LauncherStatus |
FailClient.run(Class<?> failMsgClass,
Configuration runtimeConfig,
int timeOut) |
| Modifier and Type | Method and Description |
|---|---|
static LauncherStatus |
Client.run(Class<? extends Task> failTaskClass,
Configuration runtimeConfig,
int timeOut) |
| Modifier and Type | Method and Description |
|---|---|
static LauncherStatus |
DriverMessaging.run(Configuration runtimeConfiguration,
int launcherTimeout) |
| Modifier and Type | Method and Description |
|---|---|
static LauncherStatus |
FailureREEF.runFailureReef(Configuration runtimeConfig,
int timeout) |
Copyright © 2015 The Apache Software Foundation. All rights reserved.