Package | Description |
---|---|
org.apache.reef.client |
Client APIs for REEF.
|
org.apache.reef.examples.group.bgd |
Runs BGD on the given runtime.
|
org.apache.reef.examples.group.broadcast |
Broadcast Group Communication example.
|
org.apache.reef.examples.helloCLR |
The Hello REEF example for the CLR.
|
org.apache.reef.examples.hellohttp |
Distributed shell example based on REEF HTTP Server component.
|
org.apache.reef.tests |
Tests for REEF implementations.
|
org.apache.reef.tests.fail.driver |
Tests for Driver-side failures.
|
org.apache.reef.tests.fail.task |
Tests for Tasks fail in various cases.
|
org.apache.reef.tests.messaging.driver |
Tests the messaging channel between client and driver.
|
org.apache.reef.tests.yarn.failure |
Tests for YARN failures.
|
org.apache.reef.vortex.driver |
Vortex Code that runs as part of REEF Driver.
|
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 |
---|---|
LauncherStatus |
BGDClient.run(Configuration runtimeConfiguration,
String jobName,
int timeout)
Runs BGD on the given runtime - with timeout.
|
Modifier and Type | Method and Description |
---|---|
static LauncherStatus |
BroadcastREEF.runBGDReef(Configuration runtimeConfiguration) |
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) |
Modifier and Type | Method and Description |
---|---|
static LauncherStatus |
VortexLauncher.launchLocal(VortexJobConf vortexConf)
Launch a Vortex job using the local runtime.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.