edu.iu.dsc.tws.executor.comms.batch.table

Class PartitionOperation

java.lang.Object

edu.iu.dsc.tws.executor.comms.AbstractParallelOperation

edu.iu.dsc.tws.executor.comms.batch.table.PartitionOperation

All Implemented Interfaces:

IParallelOperation

public class PartitionOperation
extends AbstractParallelOperation

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	PartitionOperation.PartitionReceiver

Field Summary

Fields

Modifier and Type	Field and Description
protected BTPartition	op

Fields inherited from class edu.iu.dsc.tws.executor.comms.AbstractParallelOperation

channel, config, inEdge, logicalPlan, outMessages, syncs

Constructor Summary

Constructors

Constructor and Description
PartitionOperation(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)

Method Summary

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

Methods inherited from class edu.iu.dsc.tws.executor.comms.AbstractParallelOperation

close, finish, progress, register, registerSync, reset

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface edu.iu.dsc.tws.api.compute.executor.IParallelOperation

sendBarrier

Field Detail

op

protected BTPartition op

Constructor Detail

PartitionOperation

public PartitionOperation(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)

Method Detail

send

public boolean send(int source,
                    IMessage message,
                    int dest)

Description copied from interface: IParallelOperation

Send a message over the operation

Parameters:

source - source

message - the message

isComplete

public boolean isComplete()

Description copied from interface: IParallelOperation

Check weather the operation is complete

Specified by:

isComplete in interface IParallelOperation

Overrides:

isComplete in class AbstractParallelOperation

Returns:

true if the operation is complete

getOp

public BaseOperation getOp()