edu.iu.dsc.tws.executor.comms.batch

Class AllReduceBatchOperation.ReduceFnImpl

java.lang.Object

edu.iu.dsc.tws.executor.comms.batch.AllReduceBatchOperation.ReduceFnImpl

All Implemented Interfaces:

ReduceFunction

Enclosing class:

AllReduceBatchOperation

public static class AllReduceBatchOperation.ReduceFnImpl
extends java.lang.Object
implements ReduceFunction

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

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