public class ReduceStreamingOperation extends AbstractParallelOperation
| Modifier and Type | Field and Description |
|---|---|
protected IFunction |
function |
protected SReduce |
op |
channel, config, inEdge, logicalPlan, outMessages, syncs| Constructor and Description |
|---|
ReduceStreamingOperation(Config config,
Communicator network,
LogicalPlan tPlan,
IFunction fnc,
java.util.Set<java.lang.Integer> sources,
java.util.Set<java.lang.Integer> dests,
Edge edge) |
| Modifier and Type | Method and Description |
|---|---|
SReduce |
getOp() |
boolean |
send(int source,
IMessage message,
int flags)
Send a message over the operation
|
close, finish, isComplete, progress, register, registerSync, resetclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitsendBarrierpublic ReduceStreamingOperation(Config config, Communicator network, LogicalPlan tPlan, IFunction fnc, java.util.Set<java.lang.Integer> sources, java.util.Set<java.lang.Integer> dests, Edge edge)
public boolean send(int source,
IMessage message,
int flags)
IParallelOperationsource - sourcemessage - the messagepublic SReduce getOp()