edu.iu.dsc.tws.comms.functions

Class ReduceIdentityFunction

java.lang.Object

edu.iu.dsc.tws.comms.functions.ReduceIdentityFunction

All Implemented Interfaces:

ReduceFunction

public class ReduceIdentityFunction
extends java.lang.Object
implements ReduceFunction

This class is the identity function for reduce operations. It will simply return the first object that is is given to the reduce method and discard the second value.

Constructor Summary

Constructors

Constructor and Description
ReduceIdentityFunction()

Method Summary

Modifier and Type	Method and Description
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 t1, java.lang.Object t2) 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

ReduceIdentityFunction

public ReduceIdentityFunction()

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

reduce

public java.lang.Object reduce(java.lang.Object t1,
                               java.lang.Object t2)

Description copied from interface: ReduceFunction

Reduce t1 and t2 to a single value

Specified by:

reduce in interface ReduceFunction

Parameters:

t1 - first value

t2 - second value

Returns:

the reduced value