Support for user defined functions in a data stream management system
    93.
    发明授权
    Support for user defined functions in a data stream management system 有权
    支持数据流管理系统中用户定义的功能

    公开(公告)号:US08543558B2

    公开(公告)日:2013-09-24

    申请号:US13244272

    申请日:2011-09-23

    IPC分类号: G06F17/00 G06F17/30

    CPC分类号: G06F8/20

    摘要: A data stream management system (DSMS) is designed to support a new user-defined function, by creating and using at least two structures as follows. A first structure (“metadata entry”) is created in response to a command for creation of the new function, and maps a single instance of a class to the function's name. A second structure is created with creation of an operator on receipt of each new continuous query that uses the new function. The second structure (“operator specific data structure”) contains a path to the newly-created instance, which path is obtained by looking up the first structure. Additional second structures are created on receipt of additional continuous queries which use the new function, but all second structures contain the same path. All continuous queries use the same instance. Repeated use of a single instance to compile and execute multiple queries eliminates repeated instantiation of the same function.

    摘要翻译: 数据流管理系统(DSMS)旨在通过如下创建和使用至少两个结构来支持新的用户定义的功能。 响应于用于创建新功能的命令创建第一个结构(“元数据条目”),并将类的单个实例映射到函数的名称。 在接收到使用新功能的每个新的连续查询时,创建第二个结构。 第二个结构(“运算符特定数据结构”)包含新创建的实例的路径,通过查找第一个结构获取哪个路径。 附加的第二个结构是在接收到使用新功能的附加连续查询时创建的,但所有第二个结构都包含相同的路径。 所有连续查询使用相同的实例。 重复使用单个实例来编译和执行多个查询消除了相同功能的重复实例化。

    Support for incrementally processing user defined aggregations in a data stream management system

    公开(公告)号:US08521867B2

    公开(公告)日:2013-08-27

    申请号:US11977437

    申请日:2007-10-20

    IPC分类号: G06F15/173 G06F17/30 G06F3/00

    CPC分类号: G06F17/30412 G06F17/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).

    Log visualization tool for a data stream processing server
    95.
    发明授权
    Log visualization tool for a data stream processing server 有权
    用于数据流处理服务器的日志可视化工具

    公开(公告)号:US08386466B2

    公开(公告)日:2013-02-26

    申请号:US12534398

    申请日:2009-08-03

    IPC分类号: G06F7/00 G06F17/00 G06F17/30

    CPC分类号: G06F17/30368

    摘要: Techniques for logging data pertaining to the operation of a data stream processing server. In one set of embodiments, logging configuration information can be received specifying a functional area of a data stream processing server to be logged. Based on the logging configuration information, logging can be dynamically enabled for objects associated with the functional area that are instantiated by the data stream processing server, and logging can be dynamically disabled for objects associated with the functional area that are discarded (or no longer used) by the data stream processing server. In another set of embodiments, a tool can be provided for visualizing the data logged by the data stream processing server.

    摘要翻译: 用于记录与数据流处理服务器的操作有关的数据的技术。 在一组实施例中,可以接收指定要记录的数据流处理服务器的功能区域的记录配置信息。 基于记录配置信息,可以对与数据流处理服务器实例化的功能区域相关联的对象动态启用日志记录,并且可以对与丢弃(或不再使用的功能区域)相关联的对象动态禁用日志记录 )由数据流处理服务器。 在另一组实施例中,可以提供用于可视化由数据流处理服务器记录的数据的工具。

    Specifying a family of logics defining windows in data stream management systems
    97.
    发明授权
    Specifying a family of logics defining windows in data stream management systems 有权
    指定数据流管理系统中定义窗口的逻辑系列

    公开(公告)号:US08103655B2

    公开(公告)日:2012-01-24

    申请号:US11927683

    申请日:2007-10-30

    IPC分类号: G06F17/30

    CPC分类号: G06F17/30964

    摘要: Simplifying a user's task in specifying a family of logics, with each logic designed to potentially select different subsets of values from the same continuous data stream at the same time instant. In one embodiment, all the logics are together specified by a common user specified software code design to accept a set of parameters, with different logics resulting from execution of the software code with different parametric values. Thus, when closely related family of logics are to be developed, the common software code may be formulated, with the code being designed to accept parameters and providing different logics for different sets of parametric values corresponding to the parameters.

    摘要翻译: 简化用户指定一系列逻辑的任务,每个逻辑设计用于在同一时刻从相同的连续数据流潜在地选择不同的值子集。 在一个实施例中,所有逻辑一起由公共用户指定的软件代码设计指定,以接受一组参数,具有由执行具有不同参数值的软件代码产生的不同逻辑。 因此,当要开发密切相关的逻辑系列时,可以制定公共软件代码,其中代码被设计为接受参数并且为对应于参数的不同参数值集合提供不同的逻辑。

    Support for user defined functions in a data stream management system
    98.
    发明授权
    Support for user defined functions in a data stream management system 有权
    支持数据流管理系统中用户定义的功能

    公开(公告)号:US08073826B2

    公开(公告)日:2011-12-06

    申请号:US11874896

    申请日:2007-10-18

    IPC分类号: G06F17/00 G06F17/30

    CPC分类号: G06F8/20

    摘要: A data stream management system (DSMS) is designed to support a new user-defined function, by creating and using at least two structures as follows. A first structure (“metadata entry”) is created in response to a command for creation of the new function, and maps a single instance of a class to the function's name. A second structure is created with creation of an operator on receipt of each new continuous query that uses the new function. The second structure (“operator specific data structure”) contains a path to the newly-created instance, which path is obtained by looking up the first structure. Additional second structures are created on receipt of additional continuous queries which use the new function, but all second structures contain the same path. All continuous queries use the same instance. Repeated use of a single instance to compile and execute multiple queries eliminates repeated instantiation of the same function.

    摘要翻译: 数据流管理系统(DSMS)旨在通过如下创建和使用至少两个结构来支持新的用户定义的功能。 响应于用于创建新功能的命令创建第一个结构(“元数据条目”),并将类的单个实例映射到函数的名称。 在接收到使用新功能的每个新的连续查询时,创建第二个结构。 第二个结构(“运算符特定数据结构”)包含新创建的实例的路径,通过查找第一个结构获取哪个路径。 附加的第二个结构是在接收到使用新功能的附加连续查询时创建的,但所有第二个结构都包含相同的路径。 所有连续查询使用相同的实例。 重复使用单个实例来编译和执行多个查询消除了相同功能的重复实例化。

    Support for user defined aggregations in a data stream management system
    99.
    发明授权
    Support for user defined aggregations in a data stream management system 有权
    支持数据流管理系统中用户定义的聚合

    公开(公告)号:US07991766B2

    公开(公告)日:2011-08-02

    申请号:US11977439

    申请日:2007-10-20

    IPC分类号: G06F7/00 G06F15/16

    CPC分类号: G06F17/30489 G06F17/30516

    摘要: A computer is programmed to accept a command to create a new aggregation defined by a user during execution of continuous queries on streams of data. The computer is further programmed to thereafter accept and process new continuous queries using the new aggregation, in a manner similar to built-in aggregations. The user typically writes a set of instructions to perform the new aggregation, and identifies in the command, a location of the set of instructions. In response to such a command, the computer creates metadata identifying the new aggregation. The metadata is used to instantiate one aggregation for each group of data in a current window, grouped by an attribute identified in a new query.

    摘要翻译: 计算机被编程为接受命令以在对数据流的连续查询执行期间创建由用户定义的新聚合。 该计算机被进一步编程为此后以类似于内置聚合的方式接受和处理使用新聚合的新的连续查询。 用户通常写一组指令来执行新的聚合,并且在命令中标识该组指令的位置。 响应于这样的命令,计算机创建标识新聚合的元数据。 元数据用于为当前窗口中的每组数据实例化一个聚合,按照新查询中标识的属性进行分组。