edu.iu.dsc.tws.comms.stream

Class SBroadCast

java.lang.Object

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

edu.iu.dsc.tws.comms.stream.SBroadCast

public class SBroadCast
extends BaseOperation

Streaming Broadcast Operation

Field Summary

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

channel, op

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
boolean	bcast(int source, java.lang.Object message, int flags) Send a message to be reduced

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

SBroadCast

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

Construct a Streaming Broadcast operation

Parameters:

comm - the communicator

plan - task plan

source - source task

targets - target tasks

rcvr - receiver

dataType - data type

SBroadCast

public SBroadCast(Communicator comm,
                  LogicalPlan plan,
                  int source,
                  java.util.Set<java.lang.Integer> targets,
                  MessageType dataType,
                  SingularReceiver rcvr)

SBroadCast

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

SBroadCast

public SBroadCast(Communicator comm,
                  LogicalPlan plan,
                  int source,
                  java.util.Set<java.lang.Integer> targets,
                  MessageType dataType,
                  SingularReceiver rcvr,
                  MessageSchema messageSchema)

Method Detail

bcast

public boolean bcast(int source,
                     java.lang.Object message,
                     int flags)

Send a message to be reduced

Parameters:

source - source

message - message

flags - message flag

Returns:

true if the message is accepted