Class AggregatorCombiner
Interface that implements Combiner for Aggregator.
Inheritance
System.Object
AggregatorCombiner
Namespace:
Assembly: Alachisoft.NCache.Web.dll
Syntax
[Serializable]
public class AggregatorCombiner : ICombiner, IDisposable
AggregatorCombiner(IAggregator, Type)
Construtor to initialize instance of class.
Declaration
public AggregatorCombiner(IAggregator aggregator, Type classType)
Parameters
Type | Name | Description |
---|---|---|
IAggregator | aggregator | instance of IAggregator |
System.Type | classType | Class data type |
BeginCombine()
Any Intialization for the parameters before actual combining begins.
Declaration
public void BeginCombine()
Implements
Combine(Object)
Reduces the task results locally so Reducer is not burdened with excessive processing.
Declaration
public void Combine(object value)
Parameters
Type | Name | Description |
---|---|---|
System.Object | value | Value for making grouped data for reducer. |
Implements
Dispose()
Declaration
public void Dispose()
FinishChunk()
When some specified chunk size is reached, combiners marks the functionality end on that chunk and send it to Reducer for further processing. And resets its internal state for next chunk.
Declaration
public object FinishChunk()
Returns
Type | Description |
---|---|
System.Object | Sends the chunk to Reducer. |