Method AggregateAll

AggregateAll(Object)

Performs given logic of aggregation on server nodes like Reduce phase operation.

Declaration

object AggregateAll(object value)

Parameters

Type	Name	Description
System.Object	value	object

Returns

Type	Description
System.Object	Returns aggregated result.

Examples

Following example illustrate the implementation of Aggregate.

string function;
//setting current aggregator function

public IntAggregator(string function)
{
   this.function = function;
}

//Implementing interface function

public object AggregateAll(object value)
{
   return calculate(value); //implement inside logic.
}
//Function to calculate values

private object calculate(object value)
{
   switch (function)
   {
       case "MIN":
           value = int.MinValue;
           return value;
       case "MAX":
           value = int.MaxValue;
           return value;
       default:
           return 0;
   }
}