edu.iu.dsc.tws.executor.comms

Class AbstractParallelOperation

java.lang.Object

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

All Implemented Interfaces:

IParallelOperation

Direct Known Subclasses:

AllGatherBatchOperation, AllGatherStreamingOperation, AllReduceBatchOperation, AllReduceStreamingOperation, BroadcastBatchOperation, BroadcastStreamingOperation, DirectBatchOperation, DirectOperation, DirectStreamingOperation, GatherBatchOperation, GatherStreamingOperation, JoinBatchOperation, KeyedGatherBatchOperation, KeyedGatherStreamingOperation, KeyedPartitionBatchOperation, KeyedPartitionStreamOperation, KeyedReduceBatchOperation, KeyedReduceStreamingOperation, PartitionBatchOperation, PartitionOperation, PartitionStreamingOperation, PipeBatchOperation, PipeOperation, ReduceBatchOperation, ReduceStreamingOperation

public abstract class AbstractParallelOperation
extends java.lang.Object
implements IParallelOperation

Field Summary

Fields

Modifier and Type	Field and Description
protected Communicator	channel
protected Config	config
protected java.lang.String	inEdge
protected LogicalPlan	logicalPlan
protected java.util.Map<java.lang.Integer,java.util.concurrent.BlockingQueue<IMessage>>	outMessages
protected java.util.Map<java.lang.Integer,ISync>	syncs

Constructor Summary

Constructors

Constructor and Description
AbstractParallelOperation(Config config, Communicator network, LogicalPlan tPlan, java.lang.String edge)

Method Summary

Modifier and Type	Method and Description
void	close() Close the parallel operation
void	finish(int source) Indicate the end of the operation
boolean	isComplete() Check weather the operation is complete
boolean	progress() Progress the parallel operation
void	register(int targetTask, java.util.concurrent.BlockingQueue<IMessage> queue) Register a queue for receiving message
void	registerSync(int targetTask, ISync sink) Register a callback to notify when a sync happens
void	reset() Refresh the operation to start from beginning

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

getOp, send, sendBarrier

Field Detail

config

protected Config config

channel

protected Communicator channel

outMessages

protected java.util.Map<java.lang.Integer,java.util.concurrent.BlockingQueue<IMessage>> outMessages

syncs

protected java.util.Map<java.lang.Integer,ISync> syncs

logicalPlan

protected LogicalPlan logicalPlan

inEdge

protected java.lang.String inEdge

Constructor Detail

AbstractParallelOperation

public AbstractParallelOperation(Config config,
                                 Communicator network,
                                 LogicalPlan tPlan,
                                 java.lang.String edge)

Method Detail

registerSync

public void registerSync(int targetTask,
                         ISync sink)

Description copied from interface: IParallelOperation

Register a callback to notify when a sync happens

Specified by:

registerSync in interface IParallelOperation

Parameters:

targetTask - the target

sink - sync

register

public void register(int targetTask,
                     java.util.concurrent.BlockingQueue<IMessage> queue)

Description copied from interface: IParallelOperation

Register a queue for receiving message

Specified by:

register in interface IParallelOperation

close

public void close()

Description copied from interface: IParallelOperation

Close the parallel operation

Specified by:

close in interface IParallelOperation

reset

public void reset()

Description copied from interface: IParallelOperation

Refresh the operation to start from beginning

Specified by:

reset in interface IParallelOperation

isComplete

public boolean isComplete()

Description copied from interface: IParallelOperation

Check weather the operation is complete

Specified by:

isComplete in interface IParallelOperation

Returns:

true if the operation is complete

finish

public void finish(int source)

Description copied from interface: IParallelOperation

Indicate the end of the operation

Specified by:

finish in interface IParallelOperation

Parameters:

source - the source

progress

public boolean progress()

Description copied from interface: IParallelOperation

Progress the parallel operation

Specified by:

progress in interface IParallelOperation