SaschaDittmann

public class MedianStdDevCombiner 
  : JsonOutReducerCombinerBase<MedianStdDevData>
{
  public override void Reduce(string key, 
    IEnumerable<string> values, 
    JsonReducerCombinerContext<MedianStdDevData> context)
  {
    var query = values
      .Select(int.Parse)
      .GroupBy(v => v)

SaschaDittmann

public class MedianStdDevMapper : MapperBase
{
  public override void Map(string inputLine, MapperContext context)
  {
    var parsed = XmlUtils.ParseXml(inputLine);

    if (parsed == null 
        || !parsed.ContainsKey("CreationDate") 
        || !parsed.ContainsKey("Text"))
    {

SaschaDittmann

public class AverageCombiner 
  : JsonInOutReducerCombinerBase<CountAverageData, CountAverageData>
{
  public override void Reduce(string key, 
    IEnumerable<CountAverageData> values, 
    JsonReducerCombinerContext<CountAverageData> context)
  {
    float sum = 0;
    float count = 0;

SaschaDittmann

public class MinMaxCountCombiner :
  JsonInOutReducerCombinerBase<MinMaxCountData, MinMaxCountData>
{
  public override void Reduce(string key, 
    IEnumerable<MinMaxCountData> values, 
    JsonReducerCombinerContext<MinMaxCountData> context)
  {
    var data = values.ToList();

    context.EmitKeyValue(key, new MinMaxCountData