Class AggregatorCombiner
Interface that implements Combiner for Aggregator.
Inheritance
System.Object
AggregatorCombiner
Namespace:
Assembly: Alachisoft.NCache.Web.dll
Syntax
[Serializable]
public class AggregatorCombiner : ICombiner, IDisposableConstructors
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 |
Methods
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. |