我有传入的数据,我想计算该数据的平均值、第 95 个和第 99 个百分位数 - 我对最后 1000 个值最感兴趣。在任何时候,我都想查询这个对象以获取三个值中的任何一个(这可以在任何时候发生,而不仅仅是当看到 mod 1000 的数字为 0 时)。有没有办法在不保留最后 1000 个样本的情况下获得这三个值?
这不一定是完美的,所以我们可以使用一些技巧来获得一个好的估计。此外,速度是另一个问题。谢谢
(我将在 C++ 中执行此操作,但我认为这并不重要)
我有传入的数据,我想计算该数据的平均值、第 95 个和第 99 个百分位数 - 我对最后 1000 个值最感兴趣。在任何时候,我都想查询这个对象以获取三个值中的任何一个(这可以在任何时候发生,而不仅仅是当看到 mod 1000 的数字为 0 时)。有没有办法在不保留最后 1000 个样本的情况下获得这三个值?
这不一定是完美的,所以我们可以使用一些技巧来获得一个好的估计。此外,速度是另一个问题。谢谢
(我将在 C++ 中执行此操作,但我认为这并不重要)
至少,您需要维护一个包含最近 1000 个元素的队列。
要保持运行平均值,请保持最近 1000 个元素的运行总数;当您将新元素添加到队列中时,您会将其值添加到总数中,并且还减去刚刚从队列中删除的最旧元素的值。返回总数除以 1000,然后就可以了。
要保持运行的第 N 个百分位数,请维护两个堆并保持堆中元素的计数;“下”堆具有较低的 N% 值,“上”堆具有上 (1-N)% 的值(例如,下 95% 的堆将有 950 个元素,而上 5% 的堆将有 50 个元素)。在任何时候,您都可以从上堆返回最低元素,这就是您的百分位数。当您从最近的值队列中删除一个元素时,也要从堆中删除该值。如果这导致堆不平衡(例如,下部堆有 951 个元素,上部堆有 49 个元素),则移动元素以平衡它们(例如,从下部堆中删除顶部元素并将其添加到上部堆)。
由于您需要两个百分位数,因此请使用三个堆 - 较低的堆具有较低的 950 个元素,中间的具有接下来的 40 个,上部具有最高的 10 个。返回中间堆的最低元素为第 95 个百分位数,最低第 99 个百分位的上堆元素。
添加和删除堆元素是 O(lg(n)),因此这是向队列和三个堆添加新元素的成本:从堆中删除最旧的队列元素 (O(lg(n)),添加新队列元素到适当的堆(O(lg(n)),并在需要时平衡堆(再次,O(lg(n))。将新元素添加到最低堆,其最高元素大于堆元素,即
if (newElement < lowestHeap.maxElement) {
lowestHeap.add(newElement)
} else if (newElement < middleHeap.maxElement) {
middleHeap.add(newElement)
} else {
highestHeap.add(newElement)
}
确保您的堆允许重复元素
首先让我们假设您有能力存储 1000 个数字(假设 k 乘以 1000,其中 k 是常数)。
保留 3 堆:
这三个堆是特殊的:heapC 还保留了指向 heapA 或 heapB 中相应元素的链接。heapA 和 heapB 也跟踪 heapC 中的相同元素。
这是它的工作方式: