edu.iu.dsc.tws.comms.batch

Class BBroadcast

java.lang.Object

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

edu.iu.dsc.tws.comms.batch.BBroadcast

public class BBroadcast
extends BaseOperation

Field Summary

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

channel, op

Constructor Summary

Constructors

Constructor and Description
BBroadcast(Communicator comm, LogicalPlanBuilder logicalPlanBuilder, BulkReceiver rcvr, MessageType dataType)
BBroadcast(Communicator comm, LogicalPlanBuilder logicalPlanBuilder, BulkReceiver rcvr, MessageType dataType, boolean useDisk)
BBroadcast(Communicator comm, LogicalPlan plan, int sources, java.util.Set<java.lang.Integer> target, BulkReceiver rcvr, MessageType dataType) Construct a Streaming Reduce operation
BBroadcast(Communicator comm, LogicalPlan plan, int sources, java.util.Set<java.lang.Integer> target, BulkReceiver rcvr, MessageType dataType, int edgeID, MessageSchema messageSchema)
BBroadcast(Communicator comm, LogicalPlan plan, int sources, java.util.Set<java.lang.Integer> target, BulkReceiver rcvr, MessageType dataType, int edgeID, MessageSchema messageSchema, boolean useDisk) Construct a Streaming Reduce operation
BBroadcast(Communicator comm, LogicalPlan plan, int sources, java.util.Set<java.lang.Integer> target, BulkReceiver rcvr, MessageType dataType, MessageSchema messageSchema)

Method Summary

Modifier and Type	Method and Description
boolean	bcast(int src, 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

BBroadcast

public BBroadcast(Communicator comm,
                  LogicalPlan plan,
                  int sources,
                  java.util.Set<java.lang.Integer> target,
                  BulkReceiver rcvr,
                  MessageType dataType,
                  int edgeID,
                  MessageSchema messageSchema,
                  boolean useDisk)

Construct a Streaming Reduce operation

Parameters:

comm - the communicator

plan - task plan

sources - source tasks

target - target tasks

rcvr - receiver

dataType - data type

BBroadcast

public BBroadcast(Communicator comm,
                  LogicalPlan plan,
                  int sources,
                  java.util.Set<java.lang.Integer> target,
                  BulkReceiver rcvr,
                  MessageType dataType,
                  int edgeID,
                  MessageSchema messageSchema)

BBroadcast

public BBroadcast(Communicator comm,
                  LogicalPlan plan,
                  int sources,
                  java.util.Set<java.lang.Integer> target,
                  BulkReceiver rcvr,
                  MessageType dataType)

Construct a Streaming Reduce operation

Parameters:

comm - the communicator

plan - task plan

sources - source tasks

target - target tasks

rcvr - receiver

dataType - data type

BBroadcast

public BBroadcast(Communicator comm,
                  LogicalPlanBuilder logicalPlanBuilder,
                  BulkReceiver rcvr,
                  MessageType dataType)

BBroadcast

public BBroadcast(Communicator comm,
                  LogicalPlanBuilder logicalPlanBuilder,
                  BulkReceiver rcvr,
                  MessageType dataType,
                  boolean useDisk)

BBroadcast

public BBroadcast(Communicator comm,
                  LogicalPlan plan,
                  int sources,
                  java.util.Set<java.lang.Integer> target,
                  BulkReceiver rcvr,
                  MessageType dataType,
                  MessageSchema messageSchema)

Method Detail

bcast

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

Send a message to be reduced

Parameters:

src - source

message - message

flags - message flag

Returns:

true if the message is accepted