edu.iu.dsc.tws.api.compute.executor

Interface IParallelOperation

All Known Implementing Classes:

AbstractParallelOperation, 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 interface IParallelOperation

Represents a parallel communication operation

Method Summary

Modifier and Type	Method and Description
default void	close() Close the parallel operation
default void	finish(int source) Indicate the end of the operation
BaseOperation	getOp()
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 sync) Register a callback to notify when a sync happens
default void	reset() Refresh the operation to start from beginning
boolean	send(int source, IMessage message, int flags) Send a message over the operation
default boolean	sendBarrier(int src, byte[] barrierId)

Method Detail

send

boolean send(int source,
             IMessage message,
             int flags)

Send a message over the operation

Parameters:

source - source

message - the message

register

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

Register a queue for receiving message

registerSync

void registerSync(int targetTask,
                  ISync sync)

Register a callback to notify when a sync happens

Parameters:

targetTask - the target

sync - sync

progress

boolean progress()

Progress the parallel operation

isComplete

boolean isComplete()

Check weather the operation is complete

Returns:

true if the operation is complete

finish

default void finish(int source)

Indicate the end of the operation

Parameters:

source - the source

close

default void close()

Close the parallel operation

reset

default void reset()

Refresh the operation to start from beginning

sendBarrier

default boolean sendBarrier(int src,
                            byte[] barrierId)

getOp

BaseOperation getOp()