| 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.