| Package | Description |
|---|---|
| org.apache.reef.driver |
Driver APIs for REEF in terms of Rx.
|
| org.apache.reef.driver.catalog | |
| org.apache.reef.io |
APIs for I/O in REEF:
org.apache.reef.io.Codecs and org.apache.reef.io.Serializers |
| org.apache.reef.task |
| Package | Description |
|---|---|
| org.apache.reef.io |
APIs for I/O in REEF:
org.apache.reef.io.Codecs and org.apache.reef.io.Serializers |
| Modifier and Type | Interface and Description |
|---|---|
interface |
FlexiblePreemptionEvent
Represents a flexible preemption request: It contains:
a set of EvaluatorRequests that the resource manager wants to have satisfied and also
a set of Evaluators it will choose to kill if the request isn't satisfied otherwise.
NOTE: This currently not implemented.
|
interface |
PreemptionEvent
Represents Preemption requests issued by the underlying resource manager.
|
interface |
PreemptionHandler
This EventHandler will receive preemption events from the underlying resourcemanager.
|
interface |
StrictPreemptionEvent
Represents a strict preemption event: It contains the set of Evaluators that the underlying resource manager will
take away from the Driver.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
NodeDescriptor
Descriptor of the physical setup of an Evaluator.
|
interface |
RackDescriptor
A rack in the cluster.
|
interface |
ResourceCatalog
A catalog of the resources available to a REEF instance.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
Accumulable<T>
Similar to
Iterable, this is an interface for objects that can return
Accumulators. |
interface |
Accumulator<T>
A basic Accumulator interface.
|
interface |
ExternalMap<T>
A Map interface for data that can be swapped out to other processes, managed
by native code, paged to disk, stored remotely, etc...
|
class |
PartitionSpec |
interface |
Spool<T>
Spool files can be appended to, and can be scanned starting at the beginning.
|
class |
Tuple<K,V> |
| Modifier and Type | Class and Description |
|---|---|
class |
HeartBeatTriggerManager
Helper class for immediately sending heartbeat messages.
|
Copyright © 2015 The Apache Software Foundation. All rights reserved.