| Package | Description |
|---|---|
| org.apache.reef.client |
Client APIs for REEF.
|
| org.apache.reef.client.parameters |
Named parameters for the REEF client API.
|
| 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.evaluator |
Evaluator-related utilities.
|
| org.apache.reef.driver.parameters |
Named parameters used by the Driver.
|
| 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.parameters |
Named parameters used by the Evaluator.
|
| 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.bgd |
Runs BGD on the given runtime.
|
| org.apache.reef.examples.group.bgd.loss |
Loss Functions for BGD.
|
| org.apache.reef.examples.group.bgd.operatornames |
Parameter names used to identify the various operators used in BGD.
|
| org.apache.reef.examples.group.bgd.parameters |
Parameters for BGD.
|
| org.apache.reef.examples.group.broadcast |
Broadcast Group Communication example.
|
| org.apache.reef.examples.group.broadcast.parameters |
Parameters for Broadcast group communication.
|
| org.apache.reef.examples.hello |
The Hello REEF example for the HDInsight.
|
| org.apache.reef.examples.hellohttp |
Distributed shell example based on REEF HTTP Server component.
|
| org.apache.reef.examples.library |
A library for distributed shell example.
|
| org.apache.reef.examples.pool |
Allocate N evaluators, submit M tasks to them, and measure the time.
|
| org.apache.reef.examples.scheduler.client |
Task scheduler example client classes.
|
| org.apache.reef.examples.scheduler.driver |
Task scheduler example driver classes.
|
| org.apache.reef.examples.suspend |
Suspend/resume demo.
|
| org.apache.reef.io |
APIs for I/O in REEF:
Codecs and
Serializers. |
| org.apache.reef.io.checkpoint |
Checkpoints that provide APIs and implementations to store and retrieve the state of a task.
|
| org.apache.reef.io.checkpoint.fs |
FileSystem based checkpoints.
|
| 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.data.output |
Data Output Service.
|
| 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.config.parameters |
Parameters for Elastic Group Communications.
|
| 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.impl.config |
TODO: Document.
|
| org.apache.reef.io.network.naming |
TODO: Document.
|
| org.apache.reef.io.network.naming.parameters |
TODO: Document.
|
| org.apache.reef.io.parameters |
Parameters for reef-common.src.main.java.org.apache.reef.io.
|
| org.apache.reef.io.storage.ram |
Implementations for RAM-based storage service.
|
| org.apache.reef.io.watcher |
Watcher subscribes events and writes them to the destination using a certain EventStream.
|
| org.apache.reef.io.watcher.param |
Parameters for Watcher.
|
| org.apache.reef.javabridge.generic |
Generic java bridge driver/client.
|
| org.apache.reef.poison.context |
Fault Injection into REEF contexts.
|
| org.apache.reef.poison.params |
Parameters of fault injections.
|
| org.apache.reef.poison.task |
Fault Injection into REEF tasks.
|
| org.apache.reef.runtime.common |
REEF implementation.
|
| 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.parameters |
Parameters used by client.
|
| 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.evaluator |
Driver-Side representations of Evaluators.
|
| org.apache.reef.runtime.common.driver.parameters |
Parameters for 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.evaluator |
Evaluator-side implementation of the REEF API.
|
| org.apache.reef.runtime.common.evaluator.parameters |
Parameters used by Evaluator.
|
| 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.launch.parameters |
Parameters of the Launcher.
|
| org.apache.reef.runtime.common.parameters |
Parameters used by runtime.
|
| org.apache.reef.runtime.common.utils |
Runtime utilities used by various REEF modules.
|
| org.apache.reef.runtime.hdinsight.parameters |
Parameters for HDInsight connection.
|
| org.apache.reef.runtime.local.client.parameters |
Parameters of the local runtime.
|
| org.apache.reef.runtime.local.process |
Infrastructure for managing processes.
|
| org.apache.reef.runtime.mesos.client.parameters |
Client-side parameters for Mesos job submission.
|
| org.apache.reef.runtime.mesos.driver.parameters |
Driver-side parameters for Mesos job submission.
|
| org.apache.reef.runtime.mesos.evaluator.parameters |
Evaluator-side parameters for Mesos job.
|
| org.apache.reef.runtime.standalone.client.parameters |
Parameters of the standalone runtime.
|
| org.apache.reef.runtime.yarn.client |
Client-side event handlers for YARN resourcemanager.
|
| org.apache.reef.runtime.yarn.client.parameters |
Client-side parameters for YARN job submission.
|
| org.apache.reef.runtime.yarn.driver |
The Driver-Side implementation of the YARN adapter for REEF.
|
| org.apache.reef.runtime.yarn.driver.parameters |
Driver-side parameters of YARN job submission.
|
| org.apache.reef.tang |
Public interfaces and factories for Tang's core API.
|
| org.apache.reef.tang.examples |
Example code from the tutorial on Tang's home page.
|
| 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.tang.implementation.java |
Private implementation classes that configure and inject code written
in Java.
|
| org.apache.reef.tang.util |
Utilities for Tang.
|
| org.apache.reef.tests |
Tests for REEF implementations.
|
| org.apache.reef.tests.driver |
Tests whether a Driver can successfully be launched and shut down.
|
| 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.group |
Tests for group communication.
|
| org.apache.reef.tests.messaging.driver |
Tests the messaging channel between client and driver.
|
| 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.statepassing |
Tests for State-passing.
|
| org.apache.reef.tests.watcher |
Test reef.io.watcher.
|
| org.apache.reef.tests.yarn.failure |
Tests for YARN failures.
|
| org.apache.reef.util.logging |
Logging handler for clr bridge.
|
| org.apache.reef.vortex.driver |
Vortex Code that runs as part of REEF Driver.
|
| 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.impl |
Wake's implementation.
|
| 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.ports.parameters |
Parameters for TCP port selection.
|
| org.apache.reef.wake.remote.transport |
Wake's remote transportation.
|
| org.apache.reef.wake.rx.impl |
Wake's RX-style communication implementation.
|
| org.apache.reef.wake.time |
Clock and time-based events(start/stop/alarm) implementation.
|
| org.apache.reef.webserver |
HTTP Server component to implement a REST API for the Driver or Evaluators.
|
| Class and Description |
|---|
| DefaultImplementation
Allows interfaces to specify a default implementation.
|
| Unit
A TANG Unit consists of an outer class and some non-static inner classes.
|
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| DefaultImplementation
Allows interfaces to specify a default implementation.
|
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| DefaultImplementation
Allows interfaces to specify a default implementation.
|
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| DefaultImplementation
Allows interfaces to specify a default implementation.
|
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Unit
A TANG Unit consists of an outer class and some non-static inner classes.
|
| Class and Description |
|---|
| Name |
| NamedParameter |
| Unit
A TANG Unit consists of an outer class and some non-static inner classes.
|
| Class and Description |
|---|
| Parameter |
| Unit
A TANG Unit consists of an outer class and some non-static inner classes.
|
| Class and Description |
|---|
| DefaultImplementation
Allows interfaces to specify a default implementation.
|
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Parameter |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Parameter |
| Unit
A TANG Unit consists of an outer class and some non-static inner classes.
|
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| Unit
A TANG Unit consists of an outer class and some non-static inner classes.
|
| Class and Description |
|---|
| Unit
A TANG Unit consists of an outer class and some non-static inner classes.
|
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| Unit
A TANG Unit consists of an outer class and some non-static inner classes.
|
| Class and Description |
|---|
| Name |
| NamedParameter |
| Parameter |
| Unit
A TANG Unit consists of an outer class and some non-static inner classes.
|
| Class and Description |
|---|
| DefaultImplementation
Allows interfaces to specify a default implementation.
|
| Class and Description |
|---|
| Name |
| NamedParameter |
| Parameter |
| Class and Description |
|---|
| Parameter |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Parameter |
| Unit
A TANG Unit consists of an outer class and some non-static inner classes.
|
| Class and Description |
|---|
| Name |
| NamedParameter |
| Parameter |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Unit
A TANG Unit consists of an outer class and some non-static inner classes.
|
| Class and Description |
|---|
| DefaultImplementation
Allows interfaces to specify a default implementation.
|
| Class and Description |
|---|
| DefaultImplementation
Allows interfaces to specify a default implementation.
|
| Name |
| Class and Description |
|---|
| DefaultImplementation
Allows interfaces to specify a default implementation.
|
| Name |
| Class and Description |
|---|
| DefaultImplementation
Allows interfaces to specify a default implementation.
|
| Name |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| Name |
| Parameter |
| Unit
A TANG Unit consists of an outer class and some non-static inner classes.
|
| Class and Description |
|---|
| Name |
| Parameter |
| Class and Description |
|---|
| Name |
| Parameter |
| Class and Description |
|---|
| Name |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Parameter |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| DefaultImplementation
Allows interfaces to specify a default implementation.
|
| Name |
| NamedParameter |
| Parameter |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Parameter |
| Class and Description |
|---|
| DefaultImplementation
Allows interfaces to specify a default implementation.
|
| Name |
| NamedParameter |
| Unit
A TANG Unit consists of an outer class and some non-static inner classes.
|
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Unit
A TANG Unit consists of an outer class and some non-static inner classes.
|
| Class and Description |
|---|
| Parameter |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| Parameter |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| DefaultImplementation
Allows interfaces to specify a default implementation.
|
| Name |
| NamedParameter |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| DefaultImplementation
Allows interfaces to specify a default implementation.
|
| Name |
| NamedParameter |
| Class and Description |
|---|
| Parameter |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| DefaultImplementation
Allows interfaces to specify a default implementation.
|
| Class and Description |
|---|
| Unit
A TANG Unit consists of an outer class and some non-static inner classes.
|
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| DefaultImplementation
Allows interfaces to specify a default implementation.
|
| Class and Description |
|---|
| Parameter |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| DefaultImplementation
Allows interfaces to specify a default implementation.
|
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| Parameter |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| DefaultImplementation
Allows interfaces to specify a default implementation.
|
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| DefaultImplementation
Allows interfaces to specify a default implementation.
|
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| DefaultImplementation
Allows interfaces to specify a default implementation.
|
| Name |
| Class and Description |
|---|
| Parameter |
| Class and Description |
|---|
| DefaultImplementation
Allows interfaces to specify a default implementation.
|
| Name |
| NamedParameter |
| Parameter |
| Class and Description |
|---|
| DefaultImplementation
Allows interfaces to specify a default implementation.
|
| Name |
| Class and Description |
|---|
| Name |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Parameter |
| Class and Description |
|---|
| Unit
A TANG Unit consists of an outer class and some non-static inner classes.
|
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Parameter |
| Unit
A TANG Unit consists of an outer class and some non-static inner classes.
|
| Class and Description |
|---|
| Name |
| NamedParameter |
| Parameter |
| Unit
A TANG Unit consists of an outer class and some non-static inner classes.
|
| Class and Description |
|---|
| Unit
A TANG Unit consists of an outer class and some non-static inner classes.
|
| Class and Description |
|---|
| Unit
A TANG Unit consists of an outer class and some non-static inner classes.
|
| Class and Description |
|---|
| Unit
A TANG Unit consists of an outer class and some non-static inner classes.
|
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| Unit
A TANG Unit consists of an outer class and some non-static inner classes.
|
| Class and Description |
|---|
| Name |
| NamedParameter |
| Unit
A TANG Unit consists of an outer class and some non-static inner classes.
|
| Class and Description |
|---|
| Name |
| NamedParameter |
| Unit
A TANG Unit consists of an outer class and some non-static inner classes.
|
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| DefaultImplementation
Allows interfaces to specify a default implementation.
|
| Name |
| NamedParameter |
| Class and Description |
|---|
| Unit
A TANG Unit consists of an outer class and some non-static inner classes.
|
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| Parameter |
| Unit
A TANG Unit consists of an outer class and some non-static inner classes.
|
| Class and Description |
|---|
| DefaultImplementation
Allows interfaces to specify a default implementation.
|
| Name |
| NamedParameter |
| Class and Description |
|---|
| DefaultImplementation
Allows interfaces to specify a default implementation.
|
| Class and Description |
|---|
| DefaultImplementation
Allows interfaces to specify a default implementation.
|
| Parameter |
| Class and Description |
|---|
| Name |
| NamedParameter |
| Class and Description |
|---|
| DefaultImplementation
Allows interfaces to specify a default implementation.
|
| Class and Description |
|---|
| Parameter |
| Class and Description |
|---|
| DefaultImplementation
Allows interfaces to specify a default implementation.
|
| Name |
| NamedParameter |
| Class and Description |
|---|
| DefaultImplementation
Allows interfaces to specify a default implementation.
|
| Name |
| NamedParameter |
| Parameter |
| Unit
A TANG Unit consists of an outer class and some non-static inner classes.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.