edu.iu.dsc.tws.comms.batch

Class BReduce

java.lang.Object

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

edu.iu.dsc.tws.comms.batch.BReduce

public class BReduce
extends BaseOperation

Batch Reduce Operation

Field Summary

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

channel, op

Constructor Summary

Constructors

Constructor and Description
BReduce(Communicator comm, LogicalPlanBuilder logicalPlanBuilder, ReduceFunction fnc, SingularReceiver rcvr, MessageType dataType)
BReduce(Communicator comm, LogicalPlan plan, java.util.Set<java.lang.Integer> sources, int target, ReduceFunction fnc, SingularReceiver rcvr, MessageType dataType)
BReduce(Communicator comm, LogicalPlan plan, java.util.Set<java.lang.Integer> sources, int target, ReduceFunction fnc, SingularReceiver rcvr, MessageType dataType, int edgeId, MessageSchema messageSchema) Construct a Streaming Reduce operation

Method Summary

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

BReduce

public BReduce(Communicator comm,
               LogicalPlan plan,
               java.util.Set<java.lang.Integer> sources,
               int target,
               ReduceFunction fnc,
               SingularReceiver rcvr,
               MessageType dataType,
               int edgeId,
               MessageSchema messageSchema)

Construct a Streaming Reduce operation

Parameters:

comm - the communicator

plan - task plan

sources - source tasks

target - target tasks

fnc - reduce function

rcvr - receiver

dataType - data type

BReduce

public BReduce(Communicator comm,
               LogicalPlan plan,
               java.util.Set<java.lang.Integer> sources,
               int target,
               ReduceFunction fnc,
               SingularReceiver rcvr,
               MessageType dataType)

BReduce

public BReduce(Communicator comm,
               LogicalPlanBuilder logicalPlanBuilder,
               ReduceFunction fnc,
               SingularReceiver rcvr,
               MessageType dataType)

Method Detail

reduce

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