edu.iu.dsc.tws.api.tset.fn

Interface ReduceFunc<T>

All Superinterfaces:

IFunction<T>, java.io.Serializable, TFunction<T,T>

All Known Subinterfaces:

AggregateFunc<T>

All Known Implementing Classes:

ReduceFunctions.ReduceFuncImpl

public interface ReduceFunc<T>
extends TFunction<T,T>, IFunction<T>

Reduce function wrapping the IFunction from the communication layer

Method Summary

Modifier and Type	Method and Description
default T	onMessage(T object1, T object2) The actual message callback
T	reduce(T t1, T t2) Reduce the t1 and t2 into a single value

Methods inherited from interface edu.iu.dsc.tws.api.tset.fn.TFunction

close, end, prepare

Method Detail

reduce

T reduce(T t1,
         T t2)

Reduce the t1 and t2 into a single value

Parameters:

t1 - input one

t2 - input two

Returns:

the reduced object

onMessage

default T onMessage(T object1,
                    T object2)

Description copied from interface: IFunction

The actual message callback

Specified by:

onMessage in interface IFunction<T>

Parameters:

object1 - the actual message

object2 - the actual message