Package | Description |
---|---|
org.apache.reef.driver.task |
Tasks and their configurations.
|
org.apache.reef.examples.suspend |
Suspend/resume demo.
|
org.apache.reef.tests.fail.driver |
Tests for Driver-side failures.
|
org.apache.reef.tests.messaging.task |
Test message exchange between the Task and the Driver.
|
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 OptionalImpl<TaskMessageSource> |
TaskConfiguration.ON_SEND_MESSAGE
Message source invoked upon each evaluator heartbeat.
|
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 |
TaskMessagingTask
A basic task that receives a message and sends it back to the driver.
|
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.