| Package | Description |
|---|---|
| org.apache.reef.client |
Client APIs for REEF.
|
| org.apache.reef.examples.data.loading | |
| 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.examples.retained_eval |
The Retained Evaluators example.
|
| org.apache.reef.examples.scheduler |
Task scheduler example based on reef-webserver
|
| org.apache.reef.tang |
Public interfaces and factories for Tang's core API.
|
| org.apache.reef.tang.examples |
Example code from the tutorial on Tang's home page.
|
| org.apache.reef.tang.examples.timer |
A more complicated version of the Timer example, including delegating
interfaces to default implementations.
|
| org.apache.reef.tang.implementation.java |
Private implementation classes that configure and inject code written
in Java.
|
| org.apache.reef.tang.util |
Miscellaneous utilities, including command line static analysis (Tint), data structures and reflection stuff.
|
| 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 | Method and Description |
|---|---|
static DriverLauncher |
DriverLauncher.getLauncher(Configuration runtimeConfiguration)
Instantiate a launcher for the given Configuration.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
DataLoadingREEF.main(String[] args) |
| Modifier and Type | Method and Description |
|---|---|
static void |
HelloHDInsight.main(String[] args) |
static void |
HelloREEFNoClient.main(String[] args) |
static void |
HelloREEF.main(String[] args)
Start Hello REEF job.
|
static void |
HelloReefYarn.main(String[] args)
Start Hello REEF job.
|
static LauncherStatus |
HelloREEF.runHelloReef(Configuration runtimeConf,
int timeOut) |
static void |
HelloREEFNoClient.runHelloReefWithoutClient(Configuration runtimeConf) |
| Modifier and Type | Method and Description |
|---|---|
static void |
HelloCLR.main(String[] args)
Start Hello REEF job.
|
static LauncherStatus |
HelloCLR.runHelloCLR(Configuration runtimeConf,
int timeOut,
File clrFolder) |
| Modifier and Type | Method and Description |
|---|---|
static void |
HelloREEFHttpYarn.main(String[] args)
Start Hello REEF job.
|
static void |
HelloREEFHttp.main(String[] args)
main program
|
static LauncherStatus |
HelloREEFHttp.runHelloReef(Configuration runtimeConf,
int timeOut)
Run Hello Reef with merged configuration
|
| Modifier and Type | Method and Description |
|---|---|
static String |
Launch.run(Configuration config)
Main method that starts the Retained Evaluators job.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
SchedulerREEF.main(String[] args)
Main program
|
static void |
SchedulerREEFYarn.main(String[] args)
Launch the scheduler with YARN client configuration
|
static void |
SchedulerREEF.runTaskScheduler(Configuration runtimeConf,
String[] args)
Run the Task scheduler.
|
| Modifier and Type | Method and Description |
|---|---|
<U> U |
Injector.getInstance(Class<U> iface)
Gets an instance of iface, or the implementation that has been bound to it.
|
<U> U |
Injector.getInstance(String iface) |
<U> U |
Injector.getNamedInstance(Class<? extends Name<U>> iface)
Gets the value stored for the given named parameter.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
TimerV1.main(String[] args) |
static void |
PrintTypeHierarchy.main(String[] args) |
| Modifier and Type | Method and Description |
|---|---|
static void |
TimerMock.main(String[] args) |
| Modifier and Type | Method and Description |
|---|---|
<U> U |
InjectorImpl.getInstance(Class<U> clazz) |
<U> U |
InjectorImpl.getInstance(String clazz) |
<T> T |
InjectorImpl.getNamedInstance(Class<? extends Name<T>> clazz) |
<T> T |
InjectorImpl.getNamedParameter(Class<? extends Name<T>> clazz) |
| Modifier and Type | Method and Description |
|---|---|
static void |
ValidateConfiguration.main(String[] argv) |
void |
ValidateConfiguration.validatePlan() |
| Modifier and Type | Method and Description |
|---|---|
static TestDriverLauncher |
TestDriverLauncher.getLauncher(Configuration runtimeConfiguration)
Instantiate a launcher for the given Configuration.
|
| 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 void |
FailureREEF.main(String[] args) |
static LauncherStatus |
FailureREEF.runFailureReef(Configuration runtimeConfig,
int timeout) |
Copyright © 2015 The Apache Software Foundation. All rights reserved.