edu.iu.dsc.tws.comms.stream

Class SDirect

java.lang.Object

edu.iu.dsc.tws.api.comms.BaseOperation

edu.iu.dsc.tws.comms.stream.SDirect

public class SDirect
extends BaseOperation

Field Summary

Fields inherited from class edu.iu.dsc.tws.api.comms.BaseOperation

channel, op

Constructor Summary

Constructors

Constructor and Description
SDirect(Communicator comm, LogicalPlanBuilder logicalPlanBuilder, MessageType dataType, SingularReceiver rcvr)
SDirect(Communicator comm, LogicalPlan plan, java.util.List<java.lang.Integer> sources, java.util.List<java.lang.Integer> targets, MessageType dataType, SingularReceiver rcvr)
SDirect(Communicator comm, LogicalPlan plan, java.util.List<java.lang.Integer> sources, java.util.List<java.lang.Integer> targets, MessageType dataType, SingularReceiver rcvr, int edgeId, MessageSchema messageSchema) Construct a Streaming partition operation
SDirect(Communicator comm, LogicalPlan plan, java.util.List<java.lang.Integer> sources, java.util.List<java.lang.Integer> targets, MessageType dataType, SingularReceiver rcvr, MessageSchema messageSchema)

Method Summary

Modifier and Type	Method and Description
boolean	insert(int src, java.lang.Object message, int flags) Send a message to be partitioned

Methods inherited from class edu.iu.dsc.tws.api.comms.BaseOperation

close, finish, isComplete, progress, progressChannel, reset, sendBarrier, waitForCompletion

Methods inherited from class java.lang.Object

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

Constructor Detail

SDirect

public SDirect(Communicator comm,
               LogicalPlan plan,
               java.util.List<java.lang.Integer> sources,
               java.util.List<java.lang.Integer> targets,
               MessageType dataType,
               SingularReceiver rcvr,
               int edgeId,
               MessageSchema messageSchema)

Construct a Streaming partition operation

Parameters:

comm - the communicator

plan - task plan

sources - source tasks

targets - target tasks

rcvr - receiver

dataType - data type

SDirect

public SDirect(Communicator comm,
               LogicalPlan plan,
               java.util.List<java.lang.Integer> sources,
               java.util.List<java.lang.Integer> targets,
               MessageType dataType,
               SingularReceiver rcvr)

SDirect

public SDirect(Communicator comm,
               LogicalPlanBuilder logicalPlanBuilder,
               MessageType dataType,
               SingularReceiver rcvr)

SDirect

public SDirect(Communicator comm,
               LogicalPlan plan,
               java.util.List<java.lang.Integer> sources,
               java.util.List<java.lang.Integer> targets,
               MessageType dataType,
               SingularReceiver rcvr,
               MessageSchema messageSchema)

Method Detail

insert

public boolean insert(int src,
                      java.lang.Object message,
                      int flags)

Send a message to be partitioned

Parameters:

src - source

message - message

flags - message flag

Returns:

true if the message is accepted