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
by deserializing the serialized input split assigned
to this evaluator
|
Modifier and Type | Interface and Description |
---|---|
interface |
GroupChanges
Represents the changes in Topology that happened in a communication group
from the last time the user asked for topology changes
|
Modifier and Type | Interface and Description |
---|---|
interface |
CommunicationGroupClient
The Task side interface of a communication group
Lets one get the operators configured for this task
and use them for communication between tasks configured
in this communication group
|
interface |
GroupCommClient
The task side interface for the Group Communication Service
|
interface |
GroupCommNetworkHandler
The global EventHandler that receives the GroupCommunicationMsg
and routes it to the relevant communication group
|
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.
|
Copyright © 2015 The Apache Software Foundation. All rights reserved.