| Package | Description |
|---|---|
| org.apache.reef.driver.task | |
| org.apache.reef.examples.data.loading | |
| org.apache.reef.examples.hello |
The Hello REEF example.
|
| org.apache.reef.examples.library | |
| org.apache.reef.examples.pool |
Allocate N evaluators, submit M tasks to them, and measure the time.
|
| org.apache.reef.examples.suspend |
suspend/resume demo.
|
| org.apache.reef.tests.fail.driver | |
| org.apache.reef.tests.fail.task | |
| org.apache.reef.tests.library.tasks | |
| org.apache.reef.tests.messaging.task | |
| org.apache.reef.tests.statepassing |
| Modifier and Type | Field and Description |
|---|---|
static RequiredImpl<Task> |
TaskConfiguration.TASK
The task to instantiate.
|
| Modifier and Type | Class and Description |
|---|---|
class |
LineCountingTask
The task that iterates over the data set to count the number of records.
|
| Modifier and Type | Class and Description |
|---|---|
class |
HelloTask
A 'hello REEF' Task.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ShellTask
Execute command, capture its stdout, and return that string to the job driver.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SleepTask
Sleep for delay seconds and quit.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SuspendTestTask
Simple do-nothing task that can send messages to the Driver and can be suspended/resumed.
|
| Modifier and Type | Class and Description |
|---|---|
class |
NoopTask
A basic task that quite successfully does nothing.
|
| Modifier and Type | Class and Description |
|---|---|
class |
FailTask
A basic task that just fails when we create it.
|
class |
FailTaskCall
A basic task that just fails when we run it.
|
class |
FailTaskClose
A basic task that just fails when we close it.
|
class |
FailTaskMsg
A basic task that just fails when we send it a message.
|
class |
FailTaskStart
A basic task that just fails when we invoke it.
|
class |
FailTaskStop
A basic task that just fails when we stop it.
|
class |
FailTaskSuspend
A basic task that just fails when we invoke it.
|
| Modifier and Type | Method and Description |
|---|---|
static LauncherStatus |
Client.run(Class<? extends Task> failTaskClass,
Configuration runtimeConfig,
int timeOut) |
| Modifier and Type | Class and Description |
|---|---|
class |
EchoTask
A Task that just sends the memento back.
|
| Modifier and Type | Class and Description |
|---|---|
class |
TaskMessagingTask
A basic task that receives a message and sends it back to the driver.
|
| Modifier and Type | Class and Description |
|---|---|
class |
StatePassingTask |
Copyright © 2015 The Apache Software Foundation. All rights reserved.