Package | Description |
---|---|
org.apache.reef.driver.task |
Tasks and their configurations.
|
org.apache.reef.runtime.common.evaluator.task.defaults |
Default implementations for the optional task interfaces.
|
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.messaging.task |
Test message exchange between the Task and the Driver.
|
org.apache.reef.vortex.evaluator |
Vortex Code that runs as part of REEF Evaluator.
|
Modifier and Type | Field and Description |
---|---|
static OptionalImpl<EventHandler<DriverMessage>> |
TaskConfiguration.ON_MESSAGE
Handler for messages from the driver.
|
Modifier and Type | Method and Description |
---|---|
void |
DefaultDriverMessageHandler.onNext(DriverMessage driverMessage) |
Modifier and Type | Method and Description |
---|---|
void |
NoopTask.DriverMessageHandler.onNext(DriverMessage driverMessage) |
Modifier and Type | Method and Description |
---|---|
void |
FailTaskMsg.onNext(DriverMessage driverMessage) |
Modifier and Type | Method and Description |
---|---|
void |
TaskMessagingTask.DriverMessageHandler.onNext(DriverMessage driverMessage) |
Modifier and Type | Method and Description |
---|---|
void |
VortexWorker.DriverMessageHandler.onNext(DriverMessage message) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.