如何对一个集合进行分组并将相同的分组应用于其他相同长度的集合？

Question

我有多个长度相同的集合，一个List<DateTime> 类型的时间戳集合和几个List<double> 类型的数据集合。 List<double 中每个索引位置的值对应于List<DateTime> 中的相应索引位置。

我希望能够通过TimeSpan 压缩所有数据集合中的数据，该TimeSpan 应用于List<DateTime>，并将时间戳分组到TimeSpan 箱中，并对每个数据集合应用相同的分组。

这是我目前“压缩”时间戳的时间序列的方式：

var someTimeStamps = new List<DateTime>(); 
                var compression = TimeSpan.FromHours(1).Ticks;
                var compressedTimeStamps = from rawData in someTimeStamps
                    group rawData by rawData.Ticks / numberTicks
                    into tickData
                    select new DateTime(tickData.Key * compression);

如何调整代码以使相同的分组也适用于数据集合List<double>？我想应用一个对每个数据组中的值进行平均的分组逻辑。我的目标是计算效率，内存消耗不是我希望在这一点上优化的问题。

例如：

List<DateTime> items：（为简单起见，以下值的顺序为（年、月、日、小时、分钟、秒）：

(1) 2018, 8, 14, 08, 20, 05 (2) 2018 年 8 月 14 日 08 年 45 月 25 日 (3) 2018 年 8 月 14 日 09 年 02 月 53 日 (4) 2018, 8, 14, 09, 34, 12 (5) 2018, 8, 14, 09, 44, 12

List<value>项目：

(1) 12 (2) 15 (3) 27 (4) 03 (5) 12

应用TimeSpan.FromHours(1) 的压缩，两个集合的期望结果是：

List<DateTime>项目：

(1) 2018, 8, 14, 08, 00, 00 (2) 2018 8 14 09 00 00

List<double> items（平均应用于每个组中的项目）

(1) 13.5（12 和 15 的平均值） (2) 14（平均 27、3 和 12）

Answer 1

你可以通过下面的代码做到这一点

List<DateTime> dateTimes = new List<DateTime>();
dateTimes.Add(new DateTime(2018, 8, 14, 08, 20, 05));
dateTimes.Add(new DateTime(2018, 8, 14, 08, 45, 25));
dateTimes.Add(new DateTime(2018, 8, 14, 09, 02, 53));
dateTimes.Add(new DateTime(2018, 8, 14, 09, 34, 12));
dateTimes.Add(new DateTime(2018, 8, 14, 09, 44, 12));

List<int> ints = new List<int>();
ints.Add(12);
ints.Add(15);
ints.Add(27);
ints.Add(03);
ints.Add(12);



var averages = dateTimes.Select((k, v) => new { k, v })
                        .GroupBy(x => new DateTime(x.k.Year, x.k.Month, x.k.Day, x.k.Hour, 0, 0))
                        .ToDictionary(g => g.Key, g => g.Select(x => ints.ElementAt(x.v)).Average());

输出：

编辑：

如果您希望将您的数据分成两个列表，如List<DateTime> 和List<double>，那么您可以将上面的字典投影到分离的键和值列表。喜欢

 List<DateTime> dateTimeList = averages.Keys.ToList();
 List<double>  valuesList = averages.Values.ToList();

如果我理解正确的话

将该问题扩展到一个时间戳系列但多个数据系列

var grouped = dateTimes
              .Zip(ints, (k, v) => new { k, v })
              .GroupBy(g => new DateTime(g.k.Year, g.k.Month, g.k.Day, g.k.Hour, 0, 0), g => g.v);

上面的代码为您提供了日期时间和 wrt 多个数据系列的压缩

尝试一次可能对你有帮助。

Answer 2

我决定对每个数据点进行一次经典迭代，因为它只需要一次迭代，而不管数据收集的数量如何（感谢我的一位朋友，他建议对这种方法进行分析）：

public void CompressData(TimeSpan compression)
    {
        //declare generic buffer value function (bid/ask here)
        var bufferFunction = new Func<int, double>(index => (Bid[index] + Ask[index]) / 2);

        Open = new List<double>();
        High = new List<double>();
        Low = new List<double>();
        Close = new List<double>();
        var lastCompTs = -1L;
        var dataBuffer = new List<double>();
        var timeStamps = new List<DateTime>();

        for (int i = 0; i < TimeStamps.Count; ++i)
        {
            var compTs = TimeStamps[i].Ticks / compression.Ticks;
            if (compTs == lastCompTs)
            {
                //same timestamp -> add to buffer
                dataBuffer.Add(bufferFunction(i));
            }
            else
            {
                if (dataBuffer.Count > 0)
                {
                    timeStamps.Add(new DateTime(compTs * compression.Ticks));
                    Open.Add(dataBuffer.First());
                    High.Add(dataBuffer.Max());
                    Low.Add(dataBuffer.Min());
                    Close.Add(dataBuffer.Last());
                }

                lastCompTs = compTs;
                dataBuffer.Clear();
            }
        }

        if (dataBuffer.Count > 0)
        {
            timeStamps.Add(new DateTime(lastCompTs * compression.Ticks));
            Open.Add(dataBuffer.First());
            High.Add(dataBuffer.Max());
            Low.Add(dataBuffer.Min());
            Close.Add(dataBuffer.Last());
        }

        //assign time series collection
        TimeStamps = timeStamps;
    }