Package | Description |
---|---|
org.apache.reef.client |
Client APIs for REEF.
|
org.apache.reef.driver.context |
Driver Contexts and their configurations.
|
org.apache.reef.driver.task |
Tasks and their configurations.
|
org.apache.reef.examples.data.loading |
A line counter example using data loading service.
|
org.apache.reef.examples.data.output |
Example application using the output service.
|
org.apache.reef.examples.group.broadcast |
Broadcast Group Communication example.
|
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.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.context |
Implementations of Driver-Side representations of Contexts running on an Evaluator.
|
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.runtime.common.driver.task |
Driver-Side representations of tasks.
|
org.apache.reef.tests.fail.driver |
Tests for Driver-side failures.
|
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<ActiveContext>> |
DriverServiceConfiguration.ON_CONTEXT_ACTIVE
Event handler for active context.
|
static OptionalImpl<EventHandler<ActiveContext>> |
DriverConfiguration.ON_CONTEXT_ACTIVE
Event handler for active context.
|
static OptionalImpl<EventHandler<ActiveContext>> |
DriverRestartConfiguration.ON_DRIVER_RESTART_CONTEXT_ACTIVE
Event handler for active context when driver restart.
|
Modifier and Type | Method and Description |
---|---|
ActiveContext |
ClosedContext.getParentContext() |
Modifier and Type | Method and Description |
---|---|
Optional<ActiveContext> |
FailedContext.getParentContext() |
Modifier and Type | Method and Description |
---|---|
ActiveContext |
SuspendedTask.getActiveContext() |
ActiveContext |
RunningTask.getActiveContext() |
ActiveContext |
CompletedTask.getActiveContext() |
Modifier and Type | Method and Description |
---|---|
Optional<ActiveContext> |
FailedTask.getActiveContext()
Access the context the task ran (and crashed) on, if it could be recovered.
|
Constructor and Description |
---|
FailedTask(String id,
String message,
Optional<String> description,
Optional<Throwable> cause,
Optional<byte[]> data,
Optional<ActiveContext> context) |
Modifier and Type | Method and Description |
---|---|
void |
LineCounter.ContextActiveHandler.onNext(ActiveContext activeContext) |
Modifier and Type | Method and Description |
---|---|
void |
OutputServiceDriver.ActiveContextHandler.onNext(ActiveContext activeContext) |
Modifier and Type | Method and Description |
---|---|
void |
BroadcastDriver.ContextActiveHandler.onNext(ActiveContext activeContext) |
Modifier and Type | Method and Description |
---|---|
void |
SchedulerDriver.ActiveContextHandler.onNext(ActiveContext context) |
Modifier and Type | Method and Description |
---|---|
boolean |
DataLoadingService.isComputeContext(ActiveContext context) |
boolean |
DataLoadingService.isDataLoadedContext(ActiveContext context)
Distinguishes data loaded contexts from compute contexts.
|
Modifier and Type | Method and Description |
---|---|
boolean |
InputFormatLoadingService.isComputeContext(ActiveContext context) |
boolean |
InputFormatLoadingService.isDataLoadedContext(ActiveContext context) |
Modifier and Type | Method and Description |
---|---|
boolean |
GroupCommDriver.isConfigured(ActiveContext activeContext)
Tests whether the activeContext is a context configured.
|
Modifier and Type | Method and Description |
---|---|
boolean |
GroupCommDriverImpl.isConfigured(ActiveContext activeContext) |
Modifier and Type | Method and Description |
---|---|
void |
Watcher.ContextActiveHandler.onNext(ActiveContext activeContext) |
Modifier and Type | Method and Description |
---|---|
static AvroActiveContext |
WatcherAvroUtil.toAvroActiveContext(ActiveContext activeContext) |
Modifier and Type | Method and Description |
---|---|
ActiveContext |
ClosedContextBridge.getParentContext() |
Modifier and Type | Method and Description |
---|---|
ActiveContextBridge |
ActiveContextBridgeFactory.getActiveContextBridge(ActiveContext context)
Instantiates a new ActiveContextBridge.
|
Modifier and Type | Method and Description |
---|---|
void |
JobDriver.ActiveContextHandler.onNext(ActiveContext context) |
void |
JobDriver.DriverRestartActiveContextHandler.onNext(ActiveContext context) |
Modifier and Type | Class and Description |
---|---|
class |
EvaluatorContext
Driver-side representation of a Context on an Evaluator.
|
Modifier and Type | Method and Description |
---|---|
ActiveContext |
ClosedContextImpl.getParentContext() |
Modifier and Type | Method and Description |
---|---|
Optional<ActiveContext> |
FailedContextImpl.getParentContext() |
Modifier and Type | Method and Description |
---|---|
ClosedContext |
EvaluatorContext.getClosedContext(ActiveContext parentContext) |
Constructor and Description |
---|
ClosedContextImpl(ActiveContext parentContext,
String contextID,
String evaluatorId,
EvaluatorDescriptor evaluatorDescriptor) |
Constructor and Description |
---|
FailedContextImpl(String id,
String message,
Optional<String> description,
Optional<Throwable> cause,
Optional<byte[]> data,
Optional<ActiveContext> parentContext,
EvaluatorDescriptor evaluatorDescriptor,
String evaluatorID) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultDriverRestartContextActiveHandler.onNext(ActiveContext activeContext) |
void |
DefaultContextActiveHandler.onNext(ActiveContext activeContext) |
Modifier and Type | Method and Description |
---|---|
void |
EvaluatorMessageDispatcher.onContextActive(ActiveContext activeContext) |
void |
EvaluatorMessageDispatcher.onDriverRestartContextActive(ActiveContext activeContext) |
Modifier and Type | Method and Description |
---|---|
ActiveContext |
SuspendedTaskImpl.getActiveContext() |
ActiveContext |
RunningTaskImpl.getActiveContext() |
ActiveContext |
CompletedTaskImpl.getActiveContext() |
Constructor and Description |
---|
CompletedTaskImpl(ActiveContext context,
byte[] message,
String id) |
SuspendedTaskImpl(ActiveContext context,
byte[] message,
String id) |
Modifier and Type | Method and Description |
---|---|
void |
FailDriverDelayedMsg.ActiveContextHandler.onNext(ActiveContext context) |
Modifier and Type | Method and Description |
---|---|
void |
WatcherTestDriver.ContextActivatedHandler.onNext(ActiveContext activeContext) |
Modifier and Type | Method and Description |
---|---|
Map<String,ActiveContext> |
ReefEventStateManager.getContexts()
get a map of contexts.
|
Modifier and Type | Method and Description |
---|---|
void |
ReefEventStateManager.ActiveContextStateHandler.onNext(ActiveContext context) |
void |
ReefEventStateManager.DriverRestartActiveContextStateHandler.onNext(ActiveContext context) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.