Uses of Class
org.apache.reef.annotations.audience.TaskSide

Packages that use TaskSide

Package	Description
org.apache.reef.examples.data.loading
org.apache.reef.io.data.loading.api
org.apache.reef.io.data.loading.impl
org.apache.reef.task
org.apache.reef.task.events

Uses of TaskSide in org.apache.reef.examples.data.loading

Classes in org.apache.reef.examples.data.loading with annotations of type TaskSide

Modifier and Type	Class and Description
class	LineCountingTask The task that iterates over the data set to count the number of records.

Uses of TaskSide in org.apache.reef.io.data.loading.api

Classes in org.apache.reef.io.data.loading.api with annotations of type TaskSide

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.

Uses of TaskSide in org.apache.reef.io.data.loading.impl

Classes in org.apache.reef.io.data.loading.impl with annotations of type TaskSide

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

Uses of TaskSide in org.apache.reef.task

Classes in org.apache.reef.task with annotations of type TaskSide

Modifier and Type	Class and Description
class	HeartBeatTriggerManager Helper class for immediately sending heartbeat messages.
interface	Task The interface for Tasks.

Uses of TaskSide in org.apache.reef.task.events

Classes in org.apache.reef.task.events with annotations of type TaskSide

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.