| Package | Description |
|---|---|
| org.apache.reef.driver |
Driver APIs for REEF in terms of Rx.
|
| org.apache.reef.evaluator.context.parameters | |
| org.apache.reef.runtime.common.client |
Implementation of the client-side REEF API.
|
| org.apache.reef.runtime.common.driver |
Implementation of the Driver-side REEF APIs.
|
| org.apache.reef.runtime.common.driver.catalog | |
| org.apache.reef.runtime.common.driver.client |
Objects representing the Client on the Driver.
|
| org.apache.reef.runtime.common.driver.context |
Implementations of Driver-Side representations of Contexts running on an Evaluator
|
| org.apache.reef.runtime.common.driver.evaluator |
Driver-Side representations of Evaluators.
|
| org.apache.reef.runtime.common.driver.resourcemanager |
Classes that interface with the resourcemanager (Local, YARN, ...) in the Driver.
|
| org.apache.reef.runtime.common.driver.task |
Driver-Side representations of tasks.
|
| org.apache.reef.runtime.common.evaluator.context |
Context implementation of the Evaluator resourcemanager.
|
| org.apache.reef.runtime.common.evaluator.task |
Task-related implementation of the Evaluator resourcemanager.
|
| org.apache.reef.runtime.common.evaluator.task.defaults |
Default implementations for the optional task interfaces.
|
| org.apache.reef.runtime.common.evaluator.task.exceptions | |
| org.apache.reef.runtime.common.files |
This package will contain the implementation of the REEF file system standard.
|
| org.apache.reef.runtime.common.launch |
Common launch code between Driver and Evaluator.
|
| org.apache.reef.runtime.common.utils | |
| org.apache.reef.runtime.hdinsight.client |
The client to submit jobs to HDInsight.
|
| org.apache.reef.runtime.local.driver |
The resource manager for the local resourcemanager
|
| org.apache.reef.runtime.yarn.driver |
The Driver-Side implementation of the YARN adapter for REEF.
|
| org.apache.reef.runtime.yarn.util | |
| org.apache.reef.util |
Various utility classes.
|
| Package | Description |
|---|---|
| org.apache.reef.runtime.common.driver.task |
Driver-Side representations of tasks.
|
| org.apache.reef.runtime.common.driver.context |
Implementations of Driver-Side representations of Contexts running on an Evaluator
|
| org.apache.reef.runtime.common.driver.evaluator |
Driver-Side representations of Evaluators.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
FlexiblePreemptionEvent
Represents a flexible preemption request: It contains:
a set of EvaluatorRequests that the resource manager wants to have satisfied and also
a set of Evaluators it will choose to kill if the request isn't satisfied otherwise.
NOTE: This currently not implemented.
|
| Modifier and Type | Class and Description |
|---|---|
class |
Services
A set of classes to be instantiated and shared as singletons within this context and all child context
|
| Modifier and Type | Class and Description |
|---|---|
class |
REEFImplementation |
class |
RunningJobImpl
Implementation of RunningJob.
|
| Modifier and Type | Class and Description |
|---|---|
class |
DriverExceptionHandler
Exception handler for exceptions thrown by client code in the Driver.
|
class |
DriverRuntimeConfiguration |
| Modifier and Type | Class and Description |
|---|---|
class |
NodeDescriptorImpl |
class |
ResourceCatalogImpl |
| Modifier and Type | Class and Description |
|---|---|
class |
ClientManager
Represents the Client in the Driver.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ClosedContextImpl
Driver side representation of a closed context.
|
class |
ContextControlHandler
Handles context control messages.
|
class |
ContextMessageImpl
Driver-side representation of a context message.
|
class |
ContextRepresenters
Driver-Side representation of all contexts on an Evaluator.
|
class |
EvaluatorContext
Driver-side representation of a Context on an Evaluator.
|
class |
FailedContextImpl
Driver-Side representation of a failed context.
|
| Modifier and Type | Class and Description |
|---|---|
class |
EvaluatorControlHandler
This class handles the sending of Evaluator control messages to the Evaluator.
|
class |
EvaluatorHeartbeatHandler
Receives heartbeats from all Evaluators and dispatches them to the right EvaluatorManager instance.
|
class |
EvaluatorManager
Manages a single Evaluator instance including all lifecycle instances:
(AllocatedEvaluator, CompletedEvaluator, FailedEvaluator).
|
class |
EvaluatorManagerFactory
Helper class that creates new EvaluatorManager instances from alloations.
|
class |
EvaluatorResourceManagerErrorHandler
The error handler receives all resourcemanager errors from all evaluators in the system.
|
class |
Evaluators
Manages all Evaluators.
|
| Modifier and Type | Class and Description |
|---|---|
class |
NodeDescriptorHandler
Updates the ResourceCatalog with a new Node.
|
class |
ResourceAllocationHandler
Handles new resource allocations by adding a new EvaluatorManager.
|
class |
ResourceManagerStatus
Manages the status of the Resource Manager.
|
class |
ResourceStatusHandler
A ResourceStatusProto message comes from the ResourceManager layer to indicate what it thinks
about the current state of a given resource.
|
| Modifier and Type | Class and Description |
|---|---|
class |
CompletedTaskImpl |
class |
RunningTaskImpl
Implements the RunningTask client interface.
|
class |
SuspendedTaskImpl |
class |
TaskMessageImpl |
class |
TaskRepresenter
Represents a Task on the Driver.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ContextManager
Manages the stack of context in the Evaluator.
|
class |
ContextRuntime
The evaluator side resourcemanager for Contexts.
|
| Modifier and Type | Class and Description |
|---|---|
class |
TaskRuntime
The execution environment for a Task.
|
| Modifier and Type | Class and Description |
|---|---|
class |
DefaultCloseHandler
Default implementation for EventHandler
|
class |
DefaultDriverMessageHandler
A default implementation of EventHandler
|
class |
DefaultSuspendHandler
Default handler for SuspendEvent
|
| Modifier and Type | Class and Description |
|---|---|
class |
TaskCallFailure
Thrown when a Task.call() throws an exception
|
class |
TaskCloseHandlerFailure
Thrown when a Task Close Handler throws an exception
|
class |
TaskMessageHandlerFailure
Thrown when a Task Message Handler throws an exception
|
class |
TaskStartHandlerFailure
Thrown when a TastStart handler throws an exception
|
class |
TaskStopHandlerFailure
Thrown when a TaskStop handler throws an exception
|
class |
TaskSuspendHandlerFailure
Thrown when a Task Suspend Handler throws an exception
|
| Modifier and Type | Class and Description |
|---|---|
class |
JobJarMaker
Utility that takes a JobSubmissionProto and turns it into a Job Submission Jar.
|
| Modifier and Type | Class and Description |
|---|---|
class |
REEFMessageCodec
Codec for REEF's control flow messages.
|
| Modifier and Type | Class and Description |
|---|---|
class |
DispatchingEStage
Delayed event router that dispatches messages to the proper event handler by type.
|
| Modifier and Type | Class and Description |
|---|---|
class |
HDInsightDriverConfiguration
ConfigurationModule to create a Driver configuration.
|
class |
HDInsightJobSubmissionHandler
Handles job submission to a HDInsight instance.
|
| Modifier and Type | Class and Description |
|---|---|
class |
LocalResourceReleaseHandler
Takes Resource Release requests and patches them through to the resource
manager.
|
class |
ResourceManager
A resource manager that uses threads to execute containers.
|
| Modifier and Type | Class and Description |
|---|---|
class |
YarnResourceRequestHandler
Accepts resource requests from the REEF layer, translates them into requests for YARN and hands them to the
appropriate handler for those.
|
| Modifier and Type | Class and Description |
|---|---|
class |
YarnTypes
Helper class that creates the various records in the YARN API
|
| Modifier and Type | Class and Description |
|---|---|
class |
ExceptionHandlingEventHandler<T>
An ExceptionHandler that wraps another one, but catches all exceptions thrown by that one and forwards them
to an ExceptionHandler.
|
Copyright © 2015 The Apache Software Foundation. All rights reserved.