Package | Description |
---|---|
org.apache.reef.client |
Client APIs for REEF.
|
org.apache.reef.driver.evaluator |
Evaluator-related utilities.
|
org.apache.reef.examples.group.broadcast |
Broadcast Group Communication example.
|
org.apache.reef.io.network.group.api.driver |
Elastic Group Communications Driver-side API Interfaces.
|
org.apache.reef.io.network.group.impl.driver |
This package contains the implementation of the driver side of the
Group Communication Service using the tree/flat topology.
|
org.apache.reef.io.watcher |
Watcher subscribes events and writes them to the destination using a certain EventStream.
|
org.apache.reef.io.watcher.util |
Utility classes for Watcher.
|
org.apache.reef.javabridge |
The Java-side of the CLR/Java bridge.
|
org.apache.reef.javabridge.generic |
Generic java bridge driver/client.
|
org.apache.reef.runtime.common.driver.defaults |
Default implementations for the optional driver-side event handlers.
|
org.apache.reef.runtime.common.driver.evaluator |
Driver-Side representations of Evaluators.
|
org.apache.reef.tests.fail.driver |
Tests for Driver-side failures.
|
org.apache.reef.tests.library.driver |
Commonly used event handler implementations in our tests.
|
org.apache.reef.tests.watcher |
Test reef.io.watcher.
|
Modifier and Type | Field and Description |
---|---|
static OptionalImpl<EventHandler<FailedTask>> |
DriverServiceConfiguration.ON_TASK_FAILED
Event handler for failed tasks.
|
static OptionalImpl<EventHandler<FailedTask>> |
DriverConfiguration.ON_TASK_FAILED
Event handler for failed tasks.
|
Modifier and Type | Method and Description |
---|---|
Optional<FailedTask> |
FailedEvaluator.getFailedTask() |
Modifier and Type | Method and Description |
---|---|
void |
BroadcastDriver.FailedTaskHandler.onNext(FailedTask failedTask) |
Modifier and Type | Method and Description |
---|---|
EStage<FailedTask> |
GroupCommServiceDriver.getGroupCommFailedTaskStage()
Not user facing but used the Group Communication Service class.
|
Modifier and Type | Method and Description |
---|---|
EStage<FailedTask> |
GroupCommDriverImpl.getGroupCommFailedTaskStage() |
Modifier and Type | Method and Description |
---|---|
void |
TopologyFailedTaskHandler.onNext(FailedTask failedTask) |
void |
GroupCommService.FailedTaskHandler.onNext(FailedTask failedTask) |
Constructor and Description |
---|
CommunicationGroupDriverImpl(Class<? extends Name<String>> groupName,
ConfigurationSerializer confSerializer,
EStage<GroupCommunicationMessage> senderStage,
BroadcastingEventHandler<RunningTask> groupCommRunningTaskHandler,
BroadcastingEventHandler<FailedTask> groupCommFailedTaskHandler,
BroadcastingEventHandler<FailedEvaluator> groupCommFailedEvaluatorHandler,
BroadcastingEventHandler<GroupCommunicationMessage> commGroupMessageHandler,
String driverId,
int numberOfTasks,
int fanOut)
Deprecated.
in 0.14. Use Tang to obtain an instance of this instead.
|
Modifier and Type | Method and Description |
---|---|
void |
Watcher.TaskFailedHandler.onNext(FailedTask failedTask) |
Modifier and Type | Method and Description |
---|---|
static AvroFailedTask |
WatcherAvroUtil.toAvroFailedTask(FailedTask failedTask) |
Constructor and Description |
---|
FailedTaskBridge(FailedTask failedTask,
ActiveContextBridgeFactory factory) |
Modifier and Type | Method and Description |
---|---|
void |
JobDriver.FailedTaskHandler.onNext(FailedTask task) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultTaskFailureHandler.onNext(FailedTask failedTask) |
Modifier and Type | Method and Description |
---|---|
void |
EvaluatorMessageDispatcher.onTaskFailed(FailedTask failedTask) |
Modifier and Type | Method and Description |
---|---|
void |
DriverFailOnFail.FailedTaskHandler.onNext(FailedTask task) |
Modifier and Type | Method and Description |
---|---|
void |
ExpectedTaskFailureHandler.onNext(FailedTask failedTask)
Checks whether the FailedTask was caused by a ExpectedTaskException.
|
Modifier and Type | Method and Description |
---|---|
void |
WatcherTestDriver.TaskFailedHandler.onNext(FailedTask failedTask) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.