edu.iu.dsc.tws.api.comms

Interface ReduceFunction

All Known Implementing Classes:

AllReduceBatchOperation.ReduceFnImpl, ReduceBatchOperation.ReduceFnImpl, ReduceIdentityFunction, ReduceOperationFunction

public interface ReduceFunction

Functions that are used for reduce operations have to be implementations of this interface. The reduce operation takes in two objects and returns the reduced value. Note: make sure not to reuse one of the incoming objects when returning the reduced values since this can cause errors

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

Method Detail

init

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

Initialize the function

Parameters:

cfg - configuration

op - options

expectedIds - for each target, expected source ids

reduce

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

Reduce t1 and t2 to a single value

Parameters:

t1 - first value

t2 - second value

Returns:

the reduced value