Package | Description |
---|---|
org.apache.reef.client |
Client APIs for REEF.
|
org.apache.reef.driver.restart |
This package provides restart event service handlers.
|
org.apache.reef.examples.data.output |
Example application using the output service.
|
org.apache.reef.examples.hello |
The Hello REEF example for the HDInsight.
|
org.apache.reef.examples.scheduler.driver |
Task scheduler example driver classes.
|
org.apache.reef.io.data.loading.api |
Data Loading Service API.
|
org.apache.reef.io.data.loading.impl |
Implementations of Data Loading Service.
|
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.messaging.task |
Test message exchange between the Task and the Driver.
|
org.apache.reef.tests.watcher |
Test reef.io.watcher.
|
org.apache.reef.webserver |
HTTP Server component to implement a REST API for the Driver or Evaluators.
|
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 |
EvaluatorPreservingEvaluatorAllocatedHandler.onNext(AllocatedEvaluator value)
Records the allocatedEvaluator ID with the DriverRuntimeRestartManager.
|
Modifier and Type | Method and Description |
---|---|
void |
OutputServiceDriver.EvaluatorAllocatedHandler.onNext(AllocatedEvaluator allocatedEvaluator) |
Modifier and Type | Method and Description |
---|---|
void |
HelloJVMOptionsDriver.EvaluatorAllocatedHandler.onNext(AllocatedEvaluator allocatedEvaluator) |
void |
HelloDriver.EvaluatorAllocatedHandler.onNext(AllocatedEvaluator allocatedEvaluator) |
Modifier and Type | Method and Description |
---|---|
void |
SchedulerDriver.EvaluatorAllocatedHandler.onNext(AllocatedEvaluator evaluator) |
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 |
Watcher.EvaluatorAllocatedHandler.onNext(AllocatedEvaluator allocatedEvaluator) |
Modifier and Type | Method and Description |
---|---|
static AvroAllocatedEvaluator |
WatcherAvroUtil.toAvroAllocatedEvaluator(AllocatedEvaluator allocatedEvaluator) |
Modifier and Type | Method and Description |
---|---|
AllocatedEvaluatorBridge |
AllocatedEvaluatorBridgeFactory.getAllocatedEvaluatorBridge(AllocatedEvaluator allocatedEvaluator,
String serverInfo)
Instantiates a new AllocatedEvaluatorBridge.
|
Modifier and Type | Method and Description |
---|---|
void |
JobDriver.AllocatedEvaluatorHandler.onNext(AllocatedEvaluator allocatedEvaluator) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultEvaluatorAllocationHandler.onNext(AllocatedEvaluator allocatedEvaluator) |
Modifier and Type | Class and Description |
---|---|
class |
AllocatedEvaluatorImpl
Driver-Side representation of an allocated evaluator.
|
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 |
WatcherTestDriver.EvaluatorAllocatedHandler.onNext(AllocatedEvaluator allocatedEvaluator) |
Modifier and Type | Method and Description |
---|---|
void |
ReefEventStateManager.AllocatedEvaluatorStateHandler.onNext(AllocatedEvaluator eval) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.