| Package | Description | 
|---|---|
| org.apache.reef.runtime.common.driver.task | 
 Driver-Side representations of tasks. 
 | 
| 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.driver.client | 
 Representations of the Client (i.e. 
 | 
| org.apache.reef.runtime.common.driver.evaluator | 
 Driver-Side representations of Evaluators. 
 | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
ContextAndTaskSubmittable
Base interface for classes that support the simultaneous submission of both Context and Task configurations. 
 | 
interface  | 
ContextSubmittable
Base interface for classes that support Context submission. 
 | 
interface  | 
PreemptionEvent
Represents Preemption requests issued by the underlying resource manager. 
 | 
interface  | 
PreemptionHandler
This EventHandler will receive preemption events from the underlying resourcemanager. 
 | 
interface  | 
StrictPreemptionEvent
Represents a strict preemption event: It contains the set of Evaluators that the underlying resource manager will
 take away from the Driver. 
 | 
interface  | 
TaskSubmittable
Base interface for classes that support Task submission. 
 | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
JobMessageObserver
The driver uses this interface to communicate with the job client. 
 | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
ActiveContext
Represents an active context on an Evaluator. 
 | 
interface  | 
ClosedContext
Represents a Context that has been closed succesfully. 
 | 
interface  | 
ContextBase
A common base interface for all Driver-side representations of Contexts. 
 | 
class  | 
ContextConfiguration
A ConfigurationModule for Context Configuration. 
 | 
interface  | 
ContextMessage
Driver-side representation of a message sent by a Context to the Driver. 
 | 
interface  | 
FailedContext
Represents Context that failed. 
 | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
AllocatedEvaluator
Represents an Evaluator that is allocated, but is not running yet. 
 | 
interface  | 
CompletedEvaluator
Represents a successfully closed Evaluator. 
 | 
class  | 
EvaluatorRequest
A request for one ore more Evaluators. 
 | 
interface  | 
EvaluatorRequestor
Interface through which Evaluators can be requested. 
 | 
interface  | 
FailedEvaluator
Represents an Evaluator that became unavailable. 
 | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
CompletedTask
Represents a completed Task. 
 | 
class  | 
FailedTask
An error message that REEF Driver gets from a failed Task. 
 | 
interface  | 
RunningTask
Represents a running Task 
 | 
interface  | 
SuspendedTask
Represents a suspended Task. 
 | 
class  | 
TaskConfigurationOptions
Configuration parameters for the TaskConfiguration class. 
 | 
interface  | 
TaskMessage
A message from a running task to the driver. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
LineCounter
Driver side for the line counting demo that uses the data loading service. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
EvaluatorException
Exception thrown to the Driver when an Evaluator becomes unusable. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
FSCheckPointServiceConfiguration
ConfigurationModule for the FSCheckPointService. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
DataLoader
The driver component for the DataLoadingService
 Also acts as the central point for resource requests
 All the allocated evaluators pass through this and
 the ones that need data loading have a context stacked
 that enables a task to get access to Data via the
  
DataSet. | 
interface  | 
DataLoadingService
All data loading services should implement this interface. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
EvaluatorToPartitionMapper<V extends org.apache.hadoop.mapred.InputSplit>
Class that tracks the mapping between
 evaluators & the data partition assigned
 to those evaluators. 
 | 
class  | 
InputFormatExternalConstructor
A Tang External Constructor to inject the required
 InputFormat 
 | 
class  | 
InputFormatLoadingService<K,V>
An implementation of  
DataLoadingService
 that uses the Hadoop InputFormat to find
 partitions of data & request resources. | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
DriverExceptionHandler
Exception handler for exceptions thrown by client code in the Driver. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
ClientConnection
Represents the communication channel to the client. 
 | 
class  | 
ClientManager
Represents the Client in the Driver. 
 | 
class  | 
JobMessageObserverImpl
An implementation of JobMessageObserver. 
 | 
| 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  | 
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. 
 | 
| 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  | 
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  | 
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. 
 | 
Copyright © 2015 The Apache Software Foundation. All rights reserved.