Package | Description |
---|---|
org.apache.reef.client |
Client APIs for REEF.
|
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.broadcast |
Broadcast Group Communication example.
|
org.apache.reef.examples.hello |
The Hello REEF example for the HDInsight.
|
org.apache.reef.examples.helloCLR |
The Hello REEF example for the CLR.
|
org.apache.reef.examples.hellohttp |
Distributed shell example based on REEF HTTP Server component.
|
org.apache.reef.examples.pool |
Allocate N evaluators, submit M tasks to them, and measure the time.
|
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.data.output |
Data Output Service.
|
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.watcher |
Watcher subscribes events and writes them to the destination using a certain EventStream.
|
org.apache.reef.javabridge.generic |
Generic java bridge driver/client.
|
org.apache.reef.runtime.common.evaluator |
Evaluator-side implementation of the REEF API.
|
org.apache.reef.tests |
Tests for REEF implementations.
|
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.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.vortex.evaluator |
Vortex Code that runs as part of REEF Evaluator.
|
org.apache.reef.wake.impl |
Wake's implementation.
|
org.apache.reef.webserver |
HTTP Server component to implement a REST API for the Driver or Evaluators.
|
Modifier and Type | Class and Description |
---|---|
class |
DriverLauncher
A launcher for REEF Drivers.
|
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 |
OutputServiceDriver
The Driver code for the output service demo app.
|
Modifier and Type | Class and Description |
---|---|
class |
BGDDriver
Driver for BGD example.
|
Modifier and Type | Class and Description |
---|---|
class |
BroadcastDriver
Driver for broadcast example.
|
Modifier and Type | Class and Description |
---|---|
class |
HelloDriver
The Driver code for the Hello REEF Application.
|
class |
HelloDriverRestart
The Restart code for the Hello REEF Application.
|
class |
HelloJVMOptionsDriver
The Driver code for the Hello JVM Options Application.
|
Modifier and Type | Class and Description |
---|---|
class |
HelloDriver
The Driver code for the Hello REEF Application.
|
Modifier and Type | Class and Description |
---|---|
class |
HttpShellJobDriver
The Driver code for the Hello REEF Http Distributed Shell Application.
|
Modifier and Type | Class and Description |
---|---|
class |
JobDriver
Allocate N evaluators, submit M tasks to them, and measure the time.
|
Modifier and Type | Class and Description |
---|---|
class |
SchedulerDriver
Driver for TaskScheduler.
|
Modifier and Type | Class and Description |
---|---|
class |
SuspendClient
Client for suspend example.
|
class |
SuspendDriver
Suspend/resume example job driver.
|
class |
SuspendTestTask
Simple do-nothing task that can send messages to the Driver and can be suspended/resumed.
|
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 . |
Modifier and Type | Class and Description |
---|---|
class |
TaskOutputService
A service class of the task output service.
|
Modifier and Type | Class and Description |
---|---|
class |
GroupCommService
The Group Communication Service.
|
Modifier and Type | Class and Description |
---|---|
class |
Watcher
Subscribe events and transfer them as wrapping with corresponding avro classes.
|
Modifier and Type | Class and Description |
---|---|
class |
JobClient
Clr Bridge Client.
|
class |
JobDriver
Generic job driver for CLRBridge.
|
Modifier and Type | Class and Description |
---|---|
class |
HeartBeatManager
Heartbeat manager.
|
Modifier and Type | Class and Description |
---|---|
class |
TestDriverLauncher
A launcher for REEF Drivers.
|
Modifier and Type | Class and Description |
---|---|
class |
DriverFailOnFail
Driver which fails on FailedTask event.
|
class |
FailDriver
Driver which fails on receiving certain message class.
|
class |
FailDriverDelayedMsg
Driver which fails due to delayed message.
|
class |
NoopTask
A basic task that quite successfully does nothing.
|
Modifier and Type | Class and Description |
---|---|
class |
Driver
Universal driver for the test REEF job that fails on different stages of execution.
|
class |
FailTaskStop
A basic task that just fails when we stop it.
|
Modifier and Type | Class and Description |
---|---|
class |
MultipleCommGroupsDriver
Driver used for testing multiple communication groups.
|
Modifier and Type | Class and Description |
---|---|
class |
DriverMessaging
Runner for DriverMessagingTest.
|
Modifier and Type | Class and Description |
---|---|
class |
TaskMessagingDriver
Driver for TaskMessagingTest.
|
class |
TaskMessagingTask
A basic task that receives a message and sends it back to the driver.
|
Modifier and Type | Class and Description |
---|---|
class |
StatePassingDriver
Driver for StatePassingTest.
|
Modifier and Type | Class and Description |
---|---|
class |
WatcherTestDriver
Driver for WatcherTest.
|
class |
WatcherTestTask
Task for WatcherTest.
|
Modifier and Type | Class and Description |
---|---|
class |
FailureDriver
Driver for failure test.
|
Modifier and Type | Class and Description |
---|---|
class |
VortexWorker
Receives commands from VortexMaster, executes them, and returns the results.
|
Modifier and Type | Class and Description |
---|---|
class |
MergingEventHandler<L,R>
An EventHandler combines two events of different types into a single Pair of events.
|
Modifier and Type | Class and Description |
---|---|
class |
ReefEventStateManager
Reef Event Manager that manages Reef states.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.