会员体验
专利管家(专利管理)
工作空间(专利管理)
风险监控(情报监控)
数据分析(专利分析)
侵权分析(诉讼无效)
联系我们
交流群
官方交流:
QQ群: 891211   
微信请扫码    >>>
现在联系顾问~
热词
    • 69. 发明申请
    • Support for incrementally processing user defined aggregations in a data stream management system
    • 支持在数据流管理系统中逐步处理用户定义的聚合
    • US20090106440A1
    • 2009-04-23
    • US11977437
    • 2007-10-20
    • Anand SrinivasanNamit JainShailendra Kumar Mishra
    • Anand SrinivasanNamit JainShailendra Kumar Mishra
    • G06F15/16
    • G06F17/30412G06F17/30516
    • A computer is programmed to accept a command for creation of a new aggregation defined by a user to process data incrementally, one tuple at a time. One or more incremental function(s) in a set of instructions written by the user to implement the new aggregation maintain(s) locally any information that is to be passed between successive invocations, to support computing the aggregation for a given set of tuples as a whole. The user writes a set of instructions to perform the aggregation incrementally, including a plus function which is repeatedly invoked, only once, for each addition to a window of a message. The user also writes a minus function to be invoked with the message, to return the value of incremental aggregation over the window after removal of the message. In such embodiments, the computer does not maintain copies of messages in the window for use by aggregation function(s).
    • 计算机被编程为接受用于创建由用户定义的新聚合的命令以逐步处理数据,一次一个元组。 由用户写入的用于实现新聚合的一组指令中的一个或多个递增函数在本地维护将在连续调用之间传递的任何信息,以支持计算给定的一组元组的聚合, 整个。 用户写入一组指令以递增地执行聚合,包括对于每个添加到消息窗口的一次,重复调用一次的加号功能。 用户还可以使用该消息写入要调用的减号函数,以便在删除消息后返回窗口上的增量聚合值。 在这样的实施例中,计算机不维护窗口中的消息副本以供聚合功能使用。
    • 70. 发明申请
    • ADDING NEW CONTINUOUS QUERIES TO A DATA STREAM MANAGEMENT SYSTEM OPERATING ON EXISTING QUERIES
    • 对现有问题的数据流管理系统增加新的连续性查询
    • US20090106214A1
    • 2009-04-23
    • US11874202
    • 2007-10-17
    • Namit JainAnand SrinivasanShailendra Kumar Mishra
    • Namit JainAnand SrinivasanShailendra Kumar Mishra
    • G06F17/30
    • G06F17/30516
    • A new continuous query to a data stream management system (DSMS) may use a stream or a relation which may or may not be used by continuous queries previously registered in the DSMS. The DSMS is programmed to modify an execution plan to accommodate execution of the new query while continuing to execute the previously registered continuous queries. The modified execution plan may include new operators and/or share existing operators. The DSMS is programmed to cause operators which output a relation to propagate a current state of the relation to each newly-coupled operator that uses the relation. The current state is propagated only to operators that have been newly coupled and have thus not yet received any state information previously. After propagation of current state to newly-coupled operators, results of processing any new data for the relation are supplied to all operators coupled thereto, including newly-coupled operators and existing operators.
    • 对数据流管理系统(DSMS)的新的连续查询可以使用可以或可能不被先前在DSMS中注册的连续查询使用的流或关系。 DSMS被编程为修改执行计划以适应新查询的执行,同时继续执行先前注册的连续查询。 修改的执行计划可以包括新的运营商和/或共享现有运营商。 DSMS被编程为使得输出关系的操作者将关系的当前状态传播到使用该关系的每个新耦合的运算符。 当前状态仅传播到已经新耦合的操作符,并且因此以前尚未接收到任何状态信息。 在将当前状态传播到新耦合的运营商之后,将与关联关系的任何新数据进行处理的结果提供给所有与之耦合的运营商,包括新耦合运营商和现有运营商。