Test fixes for Samples in PairRDDSamples and RDDSamples

This commit is contained in:
dwnichols 2016-12-13 22:44:07 -05:00
Родитель 2fe5ec409e
Коммит 3e3a209bf4
2 изменённых файлов: 6 добавлений и 2 удалений

Просмотреть файл

@ -112,7 +112,7 @@ namespace Microsoft.Spark.CSharp.Samples
new Tuple<string, int>("a", 1)
}, 2)
.CountByKey()
.ToLookup(x => x.Item1);
.ToDictionary(k => k.Item1, v => v.Item2);
foreach (var kv in countByKey)
Console.WriteLine(kv);

Просмотреть файл

@ -3,6 +3,7 @@
using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.IO;
using System.Linq;
using Microsoft.Spark.CSharp.Core;
@ -221,7 +222,10 @@ namespace Microsoft.Spark.CSharp.Samples
[Sample]
internal static void RDDCountByValueSample()
{
var countByValue = SparkCLRSamples.SparkContext.Parallelize(new int[] { 1, 2, 1, 2, 2 }, 2).CountByValue().ToArray();
var countByValue = SparkCLRSamples.SparkContext.Parallelize(new int[] { 1, 2, 1, 2, 2 }, 2)
.CountByValue()
.ToDictionary(k => k.Item1, v => v.Item2);
foreach (var item in countByValue)
Console.WriteLine(item);