org.apache.reef.io.network.group.api.operators

Interface Scatter.Sender<T>

All Superinterfaces:

GroupCommOperator

All Known Implementing Classes:

ScatterSender

Enclosing interface:

Scatter

@DefaultImplementation(value=ScatterSender.class)
public static interface Scatter.Sender<T>
extends GroupCommOperator

Sender or Root.

Method Summary

Methods

Modifier and Type	Method and Description
void	send(List<T> elements) Distributes evenly across task ids sorted lexicographically.
void	send(List<T> elements, Integer... counts) Distributes as per counts across task ids sorted lexicographically.
void	send(List<T> elements, List<? extends Identifier> order) Distributes evenly across task ids sorted using order.
void	send(List<T> elements, List<Integer> counts, List<? extends Identifier> order) Distributes as per counts across task ids sorted using order.

Methods inherited from interface org.apache.reef.io.network.group.api.operators.GroupCommOperator

getGroupName, getOperName, getVersion, initialize

Method Detail

send

void send(List<T> elements)
          throws NetworkException,
                 InterruptedException

Distributes evenly across task ids sorted lexicographically.

Throws:

NetworkException

InterruptedException

send

void send(List<T> elements,
        Integer... counts)
          throws NetworkException,
                 InterruptedException

Distributes as per counts across task ids sorted lexicographically.

Throws:

NetworkException

InterruptedException

send

void send(List<T> elements,
        List<? extends Identifier> order)
          throws NetworkException,
                 InterruptedException

Distributes evenly across task ids sorted using order.

Throws:

NetworkException

InterruptedException

send

void send(List<T> elements,
        List<Integer> counts,
        List<? extends Identifier> order)
          throws NetworkException,
                 InterruptedException

Distributes as per counts across task ids sorted using order.

Throws:

NetworkException

InterruptedException