| Package | Description |
|---|---|
| org.apache.reef.client |
Client APIs for REEF.
|
| org.apache.reef.examples.hello |
The Hello REEF example.
|
| org.apache.reef.io.data.loading.api | |
| org.apache.reef.io.data.loading.impl | |
| 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 | |
| org.apache.reef.tests.messaging.task | |
| org.apache.reef.webserver |
| Modifier and Type | Field and Description |
|---|---|
static OptionalImpl<EventHandler<AllocatedEvaluator>> |
DriverServiceConfiguration.ON_EVALUATOR_ALLOCATED
Event handler for allocated evaluators.
|
static OptionalImpl<EventHandler<AllocatedEvaluator>> |
DriverConfiguration.ON_EVALUATOR_ALLOCATED
Event handler for allocated evaluators.
|
| Modifier and Type | Method and Description |
|---|---|
void |
HelloDriver.EvaluatorAllocatedHandler.onNext(AllocatedEvaluator allocatedEvaluator) |
| Modifier and Type | Method and Description |
|---|---|
Configuration |
DataLoadingService.getContextConfiguration(AllocatedEvaluator allocatedEvaluator) |
Configuration |
DataLoadingService.getServiceConfiguration(AllocatedEvaluator allocatedEvaluator) |
void |
DataLoader.EvaluatorAllocatedHandler.onNext(AllocatedEvaluator allocatedEvaluator) |
| Modifier and Type | Method and Description |
|---|---|
Configuration |
InputFormatLoadingService.getContextConfiguration(AllocatedEvaluator allocatedEvaluator) |
Configuration |
InputFormatLoadingService.getServiceConfiguration(AllocatedEvaluator allocatedEvaluator) |
| Modifier and Type | Method and Description |
|---|---|
void |
DefaultEvaluatorAllocationHandler.onNext(AllocatedEvaluator allocatedEvaluator) |
| Modifier and Type | Method and Description |
|---|---|
void |
EvaluatorMessageDispatcher.onEvaluatorAllocated(AllocatedEvaluator allocatedEvaluator) |
| Modifier and Type | Method and Description |
|---|---|
void |
FailDriverDelayedMsg.AllocatedEvaluatorHandler.onNext(AllocatedEvaluator eval) |
void |
DriverFailOnFail.AllocatedEvaluatorHandler.onNext(AllocatedEvaluator eval) |
| Modifier and Type | Method and Description |
|---|---|
void |
TaskMessagingDriver.EvaluatorAllocatedHandler.onNext(AllocatedEvaluator eval) |
| Modifier and Type | Method and Description |
|---|---|
void |
ReefEventStateManager.AllocatedEvaluatorStateHandler.onNext(AllocatedEvaluator eval) |
Copyright © 2015 The Apache Software Foundation. All rights reserved.