@DefaultImplementation(value=ScatterSender.class) public static interface Scatter.Sender<T> extends GroupCommOperator
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.
|
getGroupName, getOperName, getVersion, initialize
void send(List<T> elements) throws NetworkException, InterruptedException
NetworkException
InterruptedException
void send(List<T> elements, Integer... counts) throws NetworkException, InterruptedException
NetworkException
InterruptedException
void send(List<T> elements, List<? extends Identifier> order) throws NetworkException, InterruptedException
NetworkException
InterruptedException
void send(List<T> elements, List<Integer> counts, List<? extends Identifier> order) throws NetworkException, InterruptedException
NetworkException
InterruptedException
Copyright © 2017 The Apache Software Foundation. All rights reserved.