Package | Description |
---|---|
org.apache.reef.driver.task |
Tasks and their configurations.
|
org.apache.reef.examples.data.loading |
A line counter example using data loading service.
|
org.apache.reef.examples.data.output |
Example application using the output service.
|
org.apache.reef.examples.group.bgd |
Runs BGD on the given runtime.
|
org.apache.reef.examples.hello |
The Hello REEF example for the HDInsight.
|
org.apache.reef.examples.library |
A library for distributed shell example.
|
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 |
Tests for Driver-side failures.
|
org.apache.reef.tests.fail.task |
Tests for Tasks fail in various cases.
|
org.apache.reef.tests.library.tasks |
Commonly used task implementations in our tests.
|
org.apache.reef.tests.messaging.task |
Test message exchange between the Task and the Driver.
|
org.apache.reef.tests.statepassing |
Tests for State-passing.
|
org.apache.reef.tests.watcher |
Test reef.io.watcher.
|
org.apache.reef.vortex.evaluator |
Vortex Code that runs as part of REEF Evaluator.
|
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 |
OutputServiceTask
The Task code for the output service demo app.
|
Modifier and Type | Class and Description |
---|---|
class |
MasterTask
Master task for BGD example.
|
class |
SlaveTask
Slave task for BGD example.
|
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
Task for StatePassingTest.
|
Modifier and Type | Class and Description |
---|---|
class |
WatcherTestTask
Task for WatcherTest.
|
Modifier and Type | Class and Description |
---|---|
class |
VortexWorker
Receives commands from VortexMaster, executes them, and returns the results.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.