edu.iu.dsc.tws.executor.comms.streaming

Class PartitionStreamingOperation

java.lang.Object

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

edu.iu.dsc.tws.executor.comms.streaming.PartitionStreamingOperation

All Implemented Interfaces:

IParallelOperation

public class PartitionStreamingOperation
extends AbstractParallelOperation

The streaming operation.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	PartitionStreamingOperation.PartitionBulkReceiver

Field Summary

Fields

Modifier and Type	Field and Description
protected SPartition	op

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

channel, config, inEdge, logicalPlan, outMessages, syncs

Constructor Summary

Constructors

Constructor and Description
PartitionStreamingOperation(Config config, Communicator network, LogicalPlan tPlan, java.util.Set<java.lang.Integer> srcs, java.util.Set<java.lang.Integer> dests, 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	send(int source, IMessage message, int flags) Send a message over the operation

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

close, finish, isComplete, 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 SPartition op

Constructor Detail

PartitionStreamingOperation

public PartitionStreamingOperation(Config config,
                                   Communicator network,
                                   LogicalPlan tPlan,
                                   java.util.Set<java.lang.Integer> srcs,
                                   java.util.Set<java.lang.Integer> dests,
                                   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 flags)

Description copied from interface: IParallelOperation

Send a message over the operation

Parameters:

source - source

message - the message

getOp

public BaseOperation getOp()