edu.iu.dsc.tws.comms.batch

Class BKeyedReduce

java.lang.Object

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

edu.iu.dsc.tws.comms.batch.BKeyedReduce

public class BKeyedReduce
extends BaseOperation

Example class for Batch keyed reduce. The reduce destination for each data point will be based on the key value related to that data point.

Field Summary

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

channel, op

Constructor Summary

Constructors

Constructor and Description
BKeyedReduce(Communicator comm, LogicalPlanBuilder logicalPlanBuilder, ReduceFunction fnc, BulkReceiver rcvr, MessageType kType, MessageType dType, DestinationSelector destSelector)
BKeyedReduce(Communicator comm, LogicalPlan plan, java.util.Set<java.lang.Integer> sources, java.util.Set<java.lang.Integer> destinations, ReduceFunction fnc, BulkReceiver rcvr, MessageType kType, MessageType dType, DestinationSelector destSelector)
BKeyedReduce(Communicator comm, LogicalPlan plan, java.util.Set<java.lang.Integer> sources, java.util.Set<java.lang.Integer> destinations, ReduceFunction fnc, BulkReceiver rcvr, MessageType kType, MessageType dType, DestinationSelector destSelector, int edgeId, MessageSchema messageSchema)
BKeyedReduce(Communicator comm, LogicalPlan plan, java.util.Set<java.lang.Integer> sources, java.util.Set<java.lang.Integer> destinations, ReduceFunction fnc, BulkReceiver rcvr, MessageType kType, MessageType dType, DestinationSelector destSelector, MessageSchema messageSchema)

Method Summary

Modifier and Type	Method and Description
boolean	reduce(int src, java.lang.Object key, java.lang.Object data, int flags)
boolean	reduce(int src, Tuple data, int flags)

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

BKeyedReduce

public BKeyedReduce(Communicator comm,
                    LogicalPlan plan,
                    java.util.Set<java.lang.Integer> sources,
                    java.util.Set<java.lang.Integer> destinations,
                    ReduceFunction fnc,
                    BulkReceiver rcvr,
                    MessageType kType,
                    MessageType dType,
                    DestinationSelector destSelector,
                    int edgeId,
                    MessageSchema messageSchema)

BKeyedReduce

public BKeyedReduce(Communicator comm,
                    LogicalPlan plan,
                    java.util.Set<java.lang.Integer> sources,
                    java.util.Set<java.lang.Integer> destinations,
                    ReduceFunction fnc,
                    BulkReceiver rcvr,
                    MessageType kType,
                    MessageType dType,
                    DestinationSelector destSelector)

BKeyedReduce

public BKeyedReduce(Communicator comm,
                    LogicalPlanBuilder logicalPlanBuilder,
                    ReduceFunction fnc,
                    BulkReceiver rcvr,
                    MessageType kType,
                    MessageType dType,
                    DestinationSelector destSelector)

BKeyedReduce

public BKeyedReduce(Communicator comm,
                    LogicalPlan plan,
                    java.util.Set<java.lang.Integer> sources,
                    java.util.Set<java.lang.Integer> destinations,
                    ReduceFunction fnc,
                    BulkReceiver rcvr,
                    MessageType kType,
                    MessageType dType,
                    DestinationSelector destSelector,
                    MessageSchema messageSchema)

Method Detail

reduce

public boolean reduce(int src,
                      java.lang.Object key,
                      java.lang.Object data,
                      int flags)

reduce

public boolean reduce(int src,
                      Tuple data,
                      int flags)