| 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.context |
Driver Contexts and their configurations.
|
| org.apache.reef.driver.restart |
This package provides restart event service handlers.
|
| org.apache.reef.driver.task |
Tasks and their configurations.
|
| org.apache.reef.evaluator.context |
Evaluator Contexts.
|
| 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.hello |
The Hello REEF example for the HDInsight.
|
| org.apache.reef.examples.scheduler.driver |
Task scheduler example driver classes.
|
| org.apache.reef.examples.suspend |
Suspend/resume demo.
|
| org.apache.reef.io.data.loading.api |
Data Loading Service API.
|
| org.apache.reef.io.naming |
Utilities for assigning Identifiers to objects and associating socket addresses with them.
|
| 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.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.network.group.impl.operators |
Implementations for Group Communication Operators.
|
| org.apache.reef.io.network.group.impl.task |
Implementations for Elastic Group Communications Task-side API.
|
| org.apache.reef.io.network.group.impl.utils |
Utilities for group communication.
|
| org.apache.reef.io.network.impl |
TODO: Document.
|
| org.apache.reef.io.network.naming |
TODO: Document.
|
| org.apache.reef.io.network.naming.serialization |
Contains naming serialization codecs.
|
| org.apache.reef.io.network.util |
Utility for REEF IO network module.
|
| 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.generic |
Generic java bridge driver/client.
|
| org.apache.reef.poison |
Fault injection for REEF.
|
| org.apache.reef.poison.context |
Fault Injection into REEF contexts.
|
| org.apache.reef.poison.task |
Fault Injection into REEF tasks.
|
| org.apache.reef.runtime.common.client |
Implementation of the client-side REEF API.
|
| org.apache.reef.runtime.common.client.api |
Client-Side Event Handlers to be implemented by a specific resourcemanager.
|
| org.apache.reef.runtime.common.client.defaults |
Default implementations for the optional client-side event handlers.
|
| org.apache.reef.runtime.common.driver |
Implementation of the Driver-side REEF APIs.
|
| 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.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.idle |
Contains the Driver idle handling and extension APIs.
|
| org.apache.reef.runtime.common.driver.resourcemanager |
Classes that interface with the resourcemanager (Local, YARN, ...) in the Driver.
|
| org.apache.reef.runtime.common.evaluator |
Evaluator-side implementation of the REEF API.
|
| org.apache.reef.runtime.common.evaluator.context.defaults |
Default implementations for the optional context interfaces.
|
| org.apache.reef.runtime.common.evaluator.task.defaults |
Default implementations for the optional task interfaces.
|
| org.apache.reef.runtime.common.evaluator.task.exceptions |
Exceptions thrown by Tasks and Task Handlers.
|
| org.apache.reef.runtime.common.launch |
Common launch code between Driver and Evaluator.
|
| org.apache.reef.runtime.common.utils |
Runtime utilities used by various REEF modules.
|
| 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.local.process |
Infrastructure for managing processes.
|
| org.apache.reef.runtime.mesos.driver |
Driver-side event handlers for Mesos resourcemanager.
|
| org.apache.reef.runtime.mesos.util |
Utility for Mesos runtime.
|
| org.apache.reef.runtime.yarn.driver |
The Driver-Side implementation of the YARN adapter for REEF.
|
| org.apache.reef.tests.fail.driver |
Tests for Driver-side failures.
|
| org.apache.reef.tests.fail.task |
Tests for Tasks fail in various cases.
|
| org.apache.reef.tests.library.driver |
Commonly used event handler implementations in our tests.
|
| org.apache.reef.tests.messaging.task |
Test message exchange between the Task and the Driver.
|
| org.apache.reef.tests.rack.awareness |
Tests for Rack-awareness.
|
| org.apache.reef.tests.watcher |
Test reef.io.watcher.
|
| org.apache.reef.util |
Utilities for using REEF on Hadoop.
|
| org.apache.reef.vortex.evaluator |
Vortex Code that runs as part of REEF Evaluator.
|
| org.apache.reef.wake |
Public interfaces and factories for Wake's core API.
|
| org.apache.reef.wake.examples.accumulate |
A key-value combiner example.
|
| org.apache.reef.wake.examples.join |
Blocking and non-blocking join example.
|
| org.apache.reef.wake.examples.p2p |
A simple pull to push adapter.
|
| org.apache.reef.wake.impl |
Wake's implementation.
|
| org.apache.reef.wake.remote |
Wake's remote communication.
|
| org.apache.reef.wake.remote.impl |
Implementations for Wake's remote communication.
|
| org.apache.reef.wake.remote.transport |
Wake's remote transportation.
|
| org.apache.reef.wake.remote.transport.netty |
Netty-based remote transport implementation.
|
| org.apache.reef.wake.rx |
Wake's RX-style communication.
|
| org.apache.reef.wake.rx.impl |
Wake's RX-style communication implementation.
|
| org.apache.reef.wake.storage |
Deprecated in 0.14.
|
| org.apache.reef.wake.time |
Clock and time-based events(start/stop/alarm) implementation.
|
| org.apache.reef.wake.time.event |
Time-based events (start/stop/alarm).
|
| org.apache.reef.wake.time.runtime | |
| org.apache.reef.wake.time.runtime.event |
Runtime-related Wake events.
|
| org.apache.reef.webserver |
HTTP Server component to implement a REST API for the Driver or Evaluators.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| Identifier
An identifier class for REEF.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Identifier
An identifier class for REEF.
|
| Class and Description |
|---|
| EStage
Stage that executes an event handler.
|
| Class and Description |
|---|
| Identifier
An identifier class for REEF.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Identifier
An identifier class for REEF.
|
| Class and Description |
|---|
| EStage
Stage that executes an event handler.
|
| EventHandler
Handler to process an event.
|
| Identifier
An identifier class for REEF.
|
| IdentifierFactory
The factory interface for Wake.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Identifier
An identifier class for REEF.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Identifier
An identifier class for REEF.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Identifier
An identifier class for REEF.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Identifier
An identifier class for REEF.
|
| IdentifierFactory
The factory interface for Wake.
|
| Stage
Stage is an execution unit for events and provides a way to reclaim its resources.
|
| Class and Description |
|---|
| Identifier
An identifier class for REEF.
|
| IdentifierFactory
The factory interface for Wake.
|
| Stage
Stage is an execution unit for events and provides a way to reclaim its resources.
|
| Class and Description |
|---|
| Identifier
An identifier class for REEF.
|
| IdentifierFactory
The factory interface for Wake.
|
| Class and Description |
|---|
| ComparableIdentifier
Identifier that can be totally ordered.
|
| Identifier
An identifier class for REEF.
|
| IdentifierFactory
The factory interface for Wake.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EStage
Stage that executes an event handler.
|
| EventHandler
Handler to process an event.
|
| Identifier
An identifier class for REEF.
|
| Stage
Stage is an execution unit for events and provides a way to reclaim its resources.
|
| Class and Description |
|---|
| Stage
Stage is an execution unit for events and provides a way to reclaim its resources.
|
| Class and Description |
|---|
| Stage
Stage is an execution unit for events and provides a way to reclaim its resources.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| AbstractEStage
An
EStage that implements metering. |
| EStage
Stage that executes an event handler.
|
| EventHandler
Handler to process an event.
|
| Identifier
An identifier class for REEF.
|
| IdentifierFactory
The factory interface for Wake.
|
| Stage
Stage is an execution unit for events and provides a way to reclaim its resources.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Identifier
An identifier class for REEF.
|
| IdentifierFactory
The factory interface for Wake.
|
| Stage
Stage is an execution unit for events and provides a way to reclaim its resources.
|
| Class and Description |
|---|
| EStage
Stage that executes an event handler.
|
| EventHandler
Handler to process an event.
|
| Identifier
An identifier class for REEF.
|
| IdentifierFactory
The factory interface for Wake.
|
| Stage
Stage is an execution unit for events and provides a way to reclaim its resources.
|
| Class and Description |
|---|
| EStage
Stage that executes an event handler.
|
| EventHandler
Handler to process an event.
|
| Stage
Stage is an execution unit for events and provides a way to reclaim its resources.
|
| Class and Description |
|---|
| EStage
Stage that executes an event handler.
|
| EventHandler
Handler to process an event.
|
| Stage
Stage is an execution unit for events and provides a way to reclaim its resources.
|
| Class and Description |
|---|
| Stage
Stage is an execution unit for events and provides a way to reclaim its resources.
|
| Class and Description |
|---|
| Stage
Stage is an execution unit for events and provides a way to reclaim its resources.
|
| Class and Description |
|---|
| Identifier
An identifier class for REEF.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
| Class and Description |
|---|
| EventHandler
Handler to process an event.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.