Package | Description |
---|---|
org.apache.reef.examples.suspend |
Suspend/resume demo.
|
org.apache.reef.task |
Tasks.
|
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 | Method and Description |
---|---|
Optional<TaskMessage> |
SuspendTestTask.getMessage()
Update driver on current state of the task.
|
Modifier and Type | Method and Description |
---|---|
static TaskMessage |
TaskMessage.from(String messageSourceID,
byte[] theBytes) |
Modifier and Type | Method and Description |
---|---|
Optional<TaskMessage> |
TaskMessageSource.getMessage() |
Modifier and Type | Method and Description |
---|---|
Optional<TaskMessage> |
NoopTask.getMessage() |
Modifier and Type | Method and Description |
---|---|
Optional<TaskMessage> |
TaskMessagingTask.getMessage() |
Modifier and Type | Method and Description |
---|---|
Optional<TaskMessage> |
WatcherTestTask.getMessage() |
Modifier and Type | Method and Description |
---|---|
Optional<TaskMessage> |
VortexWorker.getMessage() |
Copyright © 2017 The Apache Software Foundation. All rights reserved.