NCache 4.6 - Online Documentation

Sample Usage of MapReduce

In order to execute the MapReduce task after implementing the interfaces, please follow the steps below:
  •      Initialize MapReduce Task.
  MapReduceTask task = new MapReduceTask();
  •      Set Mapper, Combiner factory and Reducer factory. Add filters, if required.
   task.Mapper = new WordCountMapper();
   task.Combiner = new WordCountCombinerFactory();
   task.Reducer = new WordCountReducerFactory();
  •      Execute task on cache.
   ITrackableTask wordCount = cache.ExecuteTask(task);
  •      Optional: enumerate over the result generated using enumeration.
  ITaskResult result= wordCount.GetResult(); 
  IDictionaryEnumerator enumResult = result.GetEnumerator();
  while (enumResult.MoveNext())
    //perform operations       
See Also