估算流数据库应用中的负荷削减数据的系统和方法

摘要

公开了用于处理包含数据元组的数据流的技术，其中一些数据元组是负荷削减。负荷削减是指例如当接收的数据量变得过于庞大而难以管理时，选择性地丢弃一些数据元组的过程。当调用依赖于负荷削减元组的值（或计数）的操作时，可以使用负荷削减元组的值（或计数）来进行这类操作。例如，聚合操作可以返回与由流应用的节点处理的多个元组相关联的总数、平均、中值和/或方差。

主权项

一种在具有负荷削减的基于流的计算系统中实现的方法，该方法包括：接收由该基于流的计算系统的流节点处理的多个到来的元组；处理所接收的多个到来的元组的一个或多个；当确定已经满足负荷削减元组的至少一个条件时，在接收到时丢弃一个或多个元组；以及调用至少部分地依赖于一个或多个被处理的元组和被丢弃的一个或多个元组的操作，其中调用的操作是标点操作，所述方法还包括确定至少一个被处理的元组相对于被处理的多个到来的元组的其它元组的序数位置；确定至少一个被丢弃的元组相对于被处理的多个到来的元组的其它元组的序数位置；返回确定的序数位置作为标点操作的结果；以及基于确定的序数位置将标点数据插入数据流以由下游操作符使用。