Package | Description |
---|---|
org.apache.reef.io.network |
TODO: Document.
|
org.apache.reef.io.network.group.api.operators |
Provides the interfaces for MPI style group communication operations.
|
org.apache.reef.io.network.group.impl.operators |
Implementations for Group Communication Operators.
|
org.apache.reef.io.network.naming |
TODO: Document.
|
org.apache.reef.io.network.naming.exception |
TODO: Document.
|
Modifier and Type | Method and Description |
---|---|
void |
Connection.close()
Closes the connection.
|
void |
Connection.open()
Opens the connection.
|
Modifier and Type | Method and Description |
---|---|
List<T> |
ReduceScatter.apply(List<T> elements,
List<Integer> counts)
Apply this operation on elements where counts specify the distribution of
elements to each task.
|
List<T> |
ReduceScatter.apply(List<T> elements,
List<Integer> counts,
List<? extends Identifier> order)
Apply this operation on elements where counts specify the distribution of
elements to each task.
|
T |
AllReduce.apply(T aElement)
Apply the operation on element.
|
List<T> |
AllGather.apply(T element)
Apply the operation on element.
|
T |
AllReduce.apply(T element,
List<? extends Identifier> order)
Apply the operation on element.
|
List<T> |
AllGather.apply(T element,
List<? extends Identifier> order)
Apply the operation on element.
|
List<T> |
Scatter.Receiver.receive()
Receive the sub-list of elements targeted for the current receiver.
|
List<T> |
Gather.Receiver.receive()
Receive the elements sent by the senders in default order.
|
T |
Broadcast.Receiver.receive()
Receiver the element broadcasted by sender.
|
List<T> |
Gather.Receiver.receive(List<? extends Identifier> order)
Receive the elements sent by the senders in specified order.
|
T |
Reduce.Receiver.reduce()
Receive values sent by senders and pass them through the reduce
function in default order.
|
T |
Reduce.Receiver.reduce(List<? extends Identifier> order)
Receive values sent by senders and pass them through the reduce
function in specified order.
|
void |
Scatter.Sender.send(List<T> elements)
Distributes evenly across task ids sorted lexicographically.
|
void |
Scatter.Sender.send(List<T> elements,
Integer... counts)
Distributes as per counts across task ids sorted lexicographically.
|
void |
Scatter.Sender.send(List<T> elements,
List<? extends Identifier> order)
Distributes evenly across task ids sorted using order.
|
void |
Scatter.Sender.send(List<T> elements,
List<Integer> counts,
List<? extends Identifier> order)
Distributes as per counts across task ids sorted using order.
|
void |
Reduce.Sender.send(T element)
Send the element to the root.
|
void |
Gather.Sender.send(T element)
Send the element to the root/receiver.
|
void |
Broadcast.Sender.send(T element)
Send element to all receivers.
|
Modifier and Type | Method and Description |
---|---|
List<T> |
ScatterReceiver.receive() |
List<T> |
GatherReceiver.receive() |
T |
BroadcastReceiver.receive() |
List<T> |
GatherReceiver.receive(List<? extends Identifier> order) |
T |
ReduceReceiver.reduce() |
T |
ReduceReceiver.reduce(List<? extends Identifier> order) |
void |
Sender.send(GroupCommunicationMessage msg) |
void |
Sender.send(GroupCommunicationMessage msg,
String dest) |
void |
ScatterSender.send(List<T> elements) |
void |
ScatterSender.send(List<T> elements,
Integer... counts) |
void |
ScatterSender.send(List<T> elements,
List<? extends Identifier> order) |
void |
ScatterSender.send(List<T> elements,
List<Integer> counts,
List<? extends Identifier> order) |
void |
ReduceSender.send(T myData) |
void |
GatherSender.send(T myData) |
void |
BroadcastSender.send(T element) |
Modifier and Type | Method and Description |
---|---|
void |
LocalNameResolverImpl.register(Identifier id,
InetSocketAddress address) |
void |
LocalNameResolverImpl.unregister(Identifier id) |
Modifier and Type | Class and Description |
---|---|
class |
NamingException
Naming exception.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.