1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
 

        public static List<string> words = new List<string>
        {
            "there","is","a",
            "great","house","and",
            "an","amazing","lake",
            "there","is","a","computer",
            "running","a","new","query","there",
            "is","a","greate","server","ready","to","process",
            "map","and","reduce"
        };

        static void Main(string[] args)
        {
            // Map
            // Generate a (word, 1) key, value pair
            ILookup<string, int> map = words.AsParallel().ToLookup(p => p, k => 1);
            // End of Map
            // Reduce
            // Calculate the number of times a word appears and
            // select the words that appear more than once
            var reduce = from IGrouping<string, int> wordMap
            in map.AsParallel()
            where wordMap.Count() > 1
            select new
            { Word = wordMap.Key, Count = wordMap.Count() };
            // End of Reduce
            // Show each word and the number of times it appears
            foreach (var word in reduce)
            Console.WriteLine("Word: '{0}'; Count: {1}",
            word.Word, word.Count);
            Console.ReadLine();
        }