edu.iu.dsc.tws.comms.batch

Class BDirect

java.lang.Object

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

edu.iu.dsc.tws.comms.batch.BDirect

public class BDirect
extends BaseOperation

Field Summary

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

channel, op

Constructor Summary

Constructors

Constructor and Description
BDirect(Communicator comm, LogicalPlanBuilder logicalPlanBuilder, BulkReceiver rcvr, MessageType dataType)
BDirect(Communicator comm, LogicalPlanBuilder logicalPlanBuilder, BulkReceiver rcvr, MessageType dataType, boolean useDisk)
BDirect(Communicator comm, LogicalPlan plan, java.util.List<java.lang.Integer> sources, java.util.List<java.lang.Integer> targets, BulkReceiver rcvr, MessageType dataType) Construct a Batch AllReduce operation
BDirect(Communicator comm, LogicalPlan plan, java.util.List<java.lang.Integer> sources, java.util.List<java.lang.Integer> targets, BulkReceiver rcvr, MessageType dataType, int edgeId, MessageSchema messageSchema)
BDirect(Communicator comm, LogicalPlan plan, java.util.List<java.lang.Integer> sources, java.util.List<java.lang.Integer> targets, BulkReceiver rcvr, MessageType dataType, int edgeId, MessageSchema messageSchema, boolean useDisk)
BDirect(Communicator comm, LogicalPlan plan, java.util.List<java.lang.Integer> sources, java.util.List<java.lang.Integer> targets, BulkReceiver rcvr, MessageType dataType, MessageSchema messageSchema)

Method Summary

Modifier and Type	Method and Description
boolean	direct(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

BDirect

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

BDirect

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

BDirect

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

Construct a Batch AllReduce operation

Parameters:

comm - the communicator

plan - task plan

sources - source tasks

targets - target tasks

rcvr - receiver

dataType - data type

BDirect

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

BDirect

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

BDirect

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

Method Detail

direct

public boolean direct(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