edu.iu.dsc.tws.comms.batch

Class BAllGather

java.lang.Object

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

edu.iu.dsc.tws.comms.batch.BAllGather

public class BAllGather
extends BaseOperation

Batch ALLGather Operation

Field Summary

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

channel, op

Constructor Summary

Constructors

Constructor and Description
BAllGather(Communicator comm, LogicalPlanBuilder logicalPlanBuilder, BulkReceiver rcvr, MessageType dataType)
BAllGather(Communicator comm, LogicalPlan plan, java.util.Set<java.lang.Integer> sources, java.util.Set<java.lang.Integer> targets, BulkReceiver rcvr, MessageType dataType)
BAllGather(Communicator comm, LogicalPlan plan, java.util.Set<java.lang.Integer> sources, java.util.Set<java.lang.Integer> targets, BulkReceiver rcvr, MessageType dataType, int gatherEdgeId, int broadEdgeId, MessageSchema messageSchema) Construct a AllGather operation

Method Summary

Modifier and Type	Method and Description
boolean	gather(int src, java.lang.Object message, int flags) Send a message to be gathered
void	reset() Clean the operation, this doesn't close it

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

BAllGather

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

Construct a AllGather operation

Parameters:

comm - the communicator

plan - task plan

sources - source tasks

targets - target tasks

rcvr - receiver

dataType - data type

BAllGather

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

BAllGather

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

Method Detail

gather

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

Send a message to be gathered

Parameters:

src - source

message - message

flags - message flag

Returns:

true if the message is accepted

reset

public void reset()

Description copied from class: BaseOperation

Clean the operation, this doesn't close it

Overrides:

reset in class BaseOperation