edu.iu.dsc.tws.api.compute

Interface IFunction<T>

Type Parameters:

T - type to reduce

All Superinterfaces:

java.io.Serializable

All Known Subinterfaces:

AggregateFunc<T>, AggregateWindowedFunction<T>, FoldWindowedFunction<T,K>, ISvmIterativeReduceFunction<T>, IWindowFunction<T>, ProcessWindowedFunction<T>, ReduceFunc<T>, ReduceWindowedFunction<T>

All Known Implementing Classes:

BasicComputation.ReductionFunction, DataflowAddNodeExperiment.Aggregator, DataflowAddNodeExperiment.Aggregator1, DataflowNodeExperiment.Aggregator, DataflowNodeExperiment.Aggregator1, HelloExample.Aggregator, IterativeAccuracyReduceFunction, IterativeTestingReduce, IterativeTrainingReduce, IterativeWeightVectorReduceFunction, KMeansComputeJob.CentroidAggregator, KMeansConnectedDataflowExample.CentroidAggregator, MultiComputeTasksGraphExample.Aggregator, ParallelDataFlowsExample.Aggregator, PredictionAggregator, ReduceAggregator, ReduceFn, ReduceFunctions.ReduceFuncImpl, SourceTaskDataLoader.SimpleDataAggregator, STWindowEventTimeExample.AggregateFunctionImpl, STWindowEventTimeExample.FoldFunctionImpl, STWindowEventTimeExample.ProcessFunctionImpl, STWindowEventTimeExample.ProcessFunctionIntImpl, STWindowEventTimeExample.ReduceFunctionImpl, STWindowExample.AggregateFunctionImpl, STWindowExample.FoldFunctionImpl, STWindowExample.ProcessFunctionImpl, STWindowExample.ReduceFunctionImpl, SvmSgdOnlineRunner.ProcessWindowFunctionImpl, TaskGraphBuildTest.Aggregator, TaskSchedulerClassTest.Aggregator, TwoDataFlowsExample.Aggregator

public interface IFunction<T>
extends java.io.Serializable

Implements the reduce function

Method Summary

Modifier and Type	Method and Description
T	onMessage(T object1, T object2) The actual message callback

Method Detail

onMessage

T onMessage(T object1,
            T object2)

The actual message callback

Parameters:

object1 - the actual message

object2 - the actual message