Package | Description |
---|---|
org.apache.reef.examples.data.loading |
A line counter example using data loading service.
|
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.group.api |
Elastic Group Communications API.
|
org.apache.reef.io.network.group.api.task |
Elastic Group Communications Task-side API Interfaces.
|
org.apache.reef.task |
Tasks.
|
org.apache.reef.task.events |
Task-related events.
|
org.apache.reef.vortex.evaluator |
Vortex Code that runs as part of REEF Evaluator.
|
Modifier and Type | Class and Description |
---|---|
class |
LineCountingTask
The task that iterates over the data set to count the number of records.
|
Modifier and Type | Interface and Description |
---|---|
interface |
DataSet<K,V>
A view of the data set to be loaded
at an evaluator as an iterable of
key value pairs.
|
Modifier and Type | Class and Description |
---|---|
class |
InputFormatDataSet<K extends org.apache.hadoop.io.WritableComparable<K>,V extends org.apache.hadoop.io.Writable>
An implementation of
DataSet that reads records using a RecordReader
encoded inside an InputSplit. |
class |
InputSplitExternalConstructor
A Tang external constructor to inject an InputSplit.
|
Modifier and Type | Class and Description |
---|---|
class |
TaskOutputStreamProviderHDFS
Implementation of
TaskOutputStreamProvider . |
Modifier and Type | Interface and Description |
---|---|
interface |
GroupChanges
Represents the changes in Topology that happened in a communication group.
|
Modifier and Type | Interface and Description |
---|---|
interface |
CommunicationGroupClient
The Task side interface of a communication group.
|
interface |
GroupCommClient
The task side interface for the Group Communication Service.
|
interface |
GroupCommNetworkHandler
The global EventHandler that receives the GroupCommunicationMsg.
|
Modifier and Type | Class and Description |
---|---|
class |
HeartBeatTriggerManager
Helper class for immediately sending heartbeat messages.
|
interface |
Task
The interface for Tasks.
|
Modifier and Type | Interface and Description |
---|---|
interface |
CloseEvent
Indicates that the driver called .close() on this Task.
|
interface |
DriverMessage
Represents a message sent by the driver.
|
interface |
SuspendEvent
Event fired when the driver called suspend() on this task.
|
Modifier and Type | Class and Description |
---|---|
class |
VortexWorker
Receives commands from VortexMaster, executes them, and returns the results.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.