edu.iu.dsc.tws.comms.batch

Class BGather

java.lang.Object

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

edu.iu.dsc.tws.comms.batch.BGather

public class BGather
extends BaseOperation

Batch Gather Operation

Field Summary

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

channel, op

Constructor Summary

Constructors

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

Method Summary

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

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

BGather

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

Construct a Streaming Gather operation

Parameters:

comm - the communicator

plan - task plan

sources - source tasks

target - target tasks

rcvr - receiver

dataType - data type

useDisk - weather to use disks

BGather

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

BGather

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

BGather

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

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