Package | Description |
---|---|
org.apache.reef.client |
Client APIs for REEF.
|
org.apache.reef.driver |
Driver APIs for REEF in terms of Rx.
|
org.apache.reef.driver.evaluator |
Evaluator-related utilities.
|
org.apache.reef.driver.restart |
This package provides restart event service handlers.
|
org.apache.reef.examples.group.bgd.loss |
Loss Functions for BGD.
|
org.apache.reef.io |
APIs for I/O in REEF:
Codec s and
Serializer s. |
org.apache.reef.io.network |
TODO: Document.
|
org.apache.reef.io.network.group.api.driver |
Elastic Group Communications Driver-side API Interfaces.
|
org.apache.reef.io.network.group.api.operators |
Provides the interfaces for MPI style group communication operations.
|
org.apache.reef.io.network.group.api.task |
Elastic Group Communications Task-side API Interfaces.
|
org.apache.reef.io.network.naming |
TODO: Document.
|
org.apache.reef.io.watcher |
Watcher subscribes events and writes them to the destination using a certain EventStream.
|
org.apache.reef.runtime.common |
REEF implementation.
|
org.apache.reef.runtime.common.client.api |
Client-Side Event Handlers to be implemented by a specific resourcemanager.
|
org.apache.reef.runtime.common.driver.api |
Driver-Side Event Handlers to be implemented by a specific resource manager.
|
org.apache.reef.runtime.common.driver.client |
Objects representing the Client on the Driver.
|
org.apache.reef.runtime.common.driver.resourcemanager |
Classes that interface with the resourcemanager (Local, YARN, ...) in the Driver.
|
org.apache.reef.runtime.common.files |
This package will contain the implementation of the REEF file system standard.
|
org.apache.reef.runtime.common.utils |
Runtime utilities used by various REEF modules.
|
org.apache.reef.runtime.multi.client |
client side for the multi runtime implementation.
|
org.apache.reef.runtime.yarn.client |
Client-side event handlers for YARN resourcemanager.
|
org.apache.reef.runtime.yarn.driver |
The Driver-Side implementation of the YARN adapter for REEF.
|
org.apache.reef.tang |
Public interfaces and factories for Tang's core API.
|
org.apache.reef.tang.examples.timer |
A more complicated version of the Timer example, including delegating
interfaces to default implementations.
|
org.apache.reef.tang.formats |
Tang format classes encode and decode information that Tang gathers at
runtime.
|
org.apache.reef.vortex.driver |
Vortex Code that runs as part of REEF Driver.
|
org.apache.reef.wake.remote |
Wake's remote communication.
|
org.apache.reef.wake.remote.address |
Local address resolution.
|
org.apache.reef.wake.remote.ports |
TCP port providers.
|
org.apache.reef.wake.remote.transport |
Wake's remote transportation.
|
org.apache.reef.wake.time |
Clock and time-based events(start/stop/alarm) implementation.
|
org.apache.reef.wake.time.runtime | |
org.apache.reef.webserver |
HTTP Server component to implement a REST API for the Driver or Evaluators.
|
Modifier and Type | Interface and Description |
---|---|
interface |
REEF
The main entry point into the REEF resourcemanager.
|
interface |
RunningJob
Represents a running REEF job.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ProgressProvider
Used in the to report the progress of the REEF application.
|
Modifier and Type | Interface and Description |
---|---|
interface |
EvaluatorProcessFactory<T>
Factory to create new evaluator process setups.
|
Modifier and Type | Interface and Description |
---|---|
interface |
DriverRuntimeRestartManager
Classes implementing this interface are in charge of recording evaluator
changes as they are allocated as well as recovering Evaluators and
discovering which evaluators are lost on the event of a driver restart.
|
Modifier and Type | Interface and Description |
---|---|
interface |
LossFunction
Interface for Loss Functions.
|
Modifier and Type | Interface and Description |
---|---|
interface |
TempFileCreator
Utility to create temporary files and folders in accordance with the underlying resource manager.
|
Modifier and Type | Interface and Description |
---|---|
interface |
NetworkConnectionService
NetworkConnectionService.
|
Modifier and Type | Interface and Description |
---|---|
interface |
CommunicationGroupDriver
The driver side interface of a Communication Group
Lets one add operators and tasks.
|
interface |
GroupCommDriver
The driver side interface of Group Communication.
|
interface |
GroupCommServiceDriver |
Modifier and Type | Interface and Description |
---|---|
static interface |
Broadcast.Receiver<T>
Receivers or Non-roots.
|
static interface |
Broadcast.Sender<T>
Sender or Root.
|
static interface |
Gather.Receiver<T>
Receiver or Root.
|
static interface |
Gather.Sender<T>
Senders or non-roots.
|
static interface |
Reduce.Receiver<T>
Receiver or Root.
|
static interface |
Reduce.Sender<T>
Senders or non roots.
|
static interface |
Scatter.Receiver<T>
Receiver or non-roots.
|
static interface |
Scatter.Sender<T>
Sender or Root.
|
Modifier and Type | Interface and Description |
---|---|
interface |
CommGroupNetworkHandler
The EventHandler that receives the GroupCommunicationMsg.
|
interface |
CommunicationGroupClient
The Task side interface of a communication group.
|
interface |
CommunicationGroupServiceClient |
interface |
GroupCommClient
The task side interface for the Group Communication Service.
|
interface |
GroupCommNetworkHandler
The global EventHandler that receives the GroupCommunicationMsg.
|
Modifier and Type | Interface and Description |
---|---|
interface |
NameResolver
NameClient interface.
|
interface |
NameServer
Naming server interface.
|
Modifier and Type | Interface and Description |
---|---|
interface |
EventStream
Write events to a certain destination.
|
Modifier and Type | Interface and Description |
---|---|
interface |
UserCredentials
A holder object for REEF user credentials.
|
Modifier and Type | Interface and Description |
---|---|
interface |
JobSubmissionEvent
Event sent to Driver Runtime.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ResourceLaunchEvent
Event from Driver Process to Driver Runtime.
|
interface |
ResourceReleaseEvent
Event from Driver Process to Driver Runtime.
|
interface |
ResourceRequestEvent
Event from Driver Process to Driver Runtime.
|
Modifier and Type | Interface and Description |
---|---|
interface |
JobStatusHandler
Generic interface for job status messages' handler.
|
Modifier and Type | Interface and Description |
---|---|
interface |
NodeDescriptorEvent
Event from Driver Runtime to Driver Process.
|
interface |
ResourceStatusEvent
Event from Driver Runtime to Driver Process.
|
interface |
RuntimeStatusEvent
Event from Driver Runtime to Driver Process.
|
Modifier and Type | Interface and Description |
---|---|
interface |
FileResource
A File Resource with a FileType for use by Runtimes.
|
interface |
RuntimePathProvider
Supplies the path to the executable for process (Driver, Evaluator) launches.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ExceptionCodec
(De-)serializes exceptions.
|
Modifier and Type | Interface and Description |
---|---|
interface |
MultiRuntimeDefinitionGenerator
Defines a contract for a multi runtime definition generator.
|
Modifier and Type | Interface and Description |
---|---|
interface |
SecurityTokenProvider
Provides security token for setting up YARN container context.
|
Modifier and Type | Interface and Description |
---|---|
interface |
JobSubmissionDirectoryProvider
Provides path to job submission directory.
|
interface |
RackNameFormatter
Provides a method to retrieve the rack name from a container, which
may be dependent on the Hadoop distribution.
|
interface |
TrackingURLProvider
Implement this interface to set the tracking URL reported to YARN.
|
interface |
YarnContainerRequestHandler
Interface to request containers from YARN using AMRMClient.ContainerRequest requests.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ClassHierarchySerializer
A base interface for ClassHierarchy serializers.
|
Modifier and Type | Interface and Description |
---|---|
interface |
Timer |
Modifier and Type | Interface and Description |
---|---|
interface |
ConfigurationSerializer
A base interface for Configuration serializers.
|
Modifier and Type | Interface and Description |
---|---|
interface |
VortexMaster
The heart of Vortex.
|
Modifier and Type | Interface and Description |
---|---|
interface |
RemoteIdentifierFactory
Factory that creates a RemoteIdentifier.
|
interface |
RemoteManager
Represents all remote connections to and from one process to another.
|
interface |
RemoteManagerFactory
Injectable Factory for RemoteManager instances.
|
Modifier and Type | Interface and Description |
---|---|
interface |
LocalAddressProvider
Injectable class that provides the local address of the node to bind to.
|
Modifier and Type | Interface and Description |
---|---|
interface |
TcpPortProvider
Provides an iterator that returns port numbers.
|
Modifier and Type | Interface and Description |
---|---|
interface |
TransportFactory
Factory that creates a transport.
|
Modifier and Type | Interface and Description |
---|---|
interface |
Clock
Represents a clock.
|
Modifier and Type | Interface and Description |
---|---|
interface |
Timer
An interface for Timer.
|
Modifier and Type | Interface and Description |
---|---|
interface |
DriverInfoSerializer
Interface for DriverInfoSerializer.
|
interface |
EvaluatorInfoSerializer
Interface for EvaluatorInfoSerializer.
|
interface |
EvaluatorListSerializer
Interface for EvaluatorListSerializer.
|
interface |
HttpServer
HttpServer interface.
|
Copyright © 2017 The Apache Software Foundation. All rights reserved.