public class DirectOperation extends AbstractParallelOperation
Modifier and Type | Class and Description |
---|---|
class |
DirectOperation.PartitionReceiver |
Modifier and Type | Field and Description |
---|---|
protected STPartition |
op |
channel, config, inEdge, logicalPlan, outMessages, syncs
Constructor and Description |
---|
DirectOperation(Config config,
Communicator network,
LogicalPlan tPlan,
java.util.Set<java.lang.Integer> sources,
java.util.Set<java.lang.Integer> targets,
Edge edge,
java.util.Map<java.lang.Integer,java.lang.Integer> srcGlobalToIndex,
java.util.Map<java.lang.Integer,java.lang.Integer> tgtsGlobalToIndex) |
Modifier and Type | Method and Description |
---|---|
BaseOperation |
getOp() |
boolean |
isComplete()
Check weather the operation is complete
|
boolean |
send(int source,
IMessage message,
int dest)
Send a message over the operation
|
close, finish, progress, register, registerSync, reset
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
sendBarrier
protected STPartition op
public DirectOperation(Config config, Communicator network, LogicalPlan tPlan, java.util.Set<java.lang.Integer> sources, java.util.Set<java.lang.Integer> targets, Edge edge, java.util.Map<java.lang.Integer,java.lang.Integer> srcGlobalToIndex, java.util.Map<java.lang.Integer,java.lang.Integer> tgtsGlobalToIndex)
public boolean send(int source, IMessage message, int dest)
IParallelOperation
source
- sourcemessage
- the messagepublic boolean isComplete()
IParallelOperation
isComplete
in interface IParallelOperation
isComplete
in class AbstractParallelOperation
public BaseOperation getOp()