edu.iu.dsc.tws.comms.functions.reduction

Class ReduceOperationFunction

java.lang.Object

edu.iu.dsc.tws.comms.functions.reduction.ReduceOperationFunction

All Implemented Interfaces:

ReduceFunction

public class ReduceOperationFunction
extends java.lang.Object
implements ReduceFunction

Constructor Summary

Constructors

Constructor and Description
ReduceOperationFunction(Op operation, MessageType dtype)

Method Summary

Modifier and Type	Method and Description
java.lang.Object	applyOp(java.lang.Object data1, java.lang.Object data2, AbstractOp op) Applying the operation on data
void	init(Config cfg, DataFlowOperation op, java.util.Map<java.lang.Integer,java.util.List<java.lang.Integer>> expectedIds) Initialize the function
java.lang.Object	reduce(java.lang.Object data1, java.lang.Object data2) Reduce t1 and t2 to a single value

Methods inherited from class java.lang.Object

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

Constructor Detail

ReduceOperationFunction

public ReduceOperationFunction(Op operation,
                               MessageType dtype)

Method Detail

init

public void init(Config cfg,
                 DataFlowOperation op,
                 java.util.Map<java.lang.Integer,java.util.List<java.lang.Integer>> expectedIds)

Description copied from interface: ReduceFunction

Initialize the function

Specified by:

init in interface ReduceFunction

Parameters:

cfg - configuration

op - options

expectedIds - for each target, expected source ids

applyOp

public java.lang.Object applyOp(java.lang.Object data1,
                                java.lang.Object data2,
                                AbstractOp op)

Applying the operation on data

reduce

public java.lang.Object reduce(java.lang.Object data1,
                               java.lang.Object data2)

Description copied from interface: ReduceFunction

Reduce t1 and t2 to a single value

Specified by:

reduce in interface ReduceFunction

Parameters:

data1 - first value

data2 - second value

Returns:

the reduced value