EXTENSIBLE LANGUAGE FRAMEWORK USING DATA CARTRIDGES
    1.
    发明申请
    EXTENSIBLE LANGUAGE FRAMEWORK USING DATA CARTRIDGES 有权
    使用数据库的可扩展语言框架

    公开(公告)号:US20110161356A1

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

    申请号:US12957201

    申请日:2010-11-30

    IPC分类号: G06F17/30

    CPC分类号: G06F17/30516 G06F17/30557

    摘要: A framework for extending the capabilities of an event processing system using one or more plug-in components referred to herein as data cartridges. In one set of embodiments, the data cartridge framework described herein can enable an event processing system to support one or more extension languages that are distinct from the native event processing language supported by the system. For example, certain “extension language” data cartridges can be provided that enable an event processing system to support complex data types and associated methods/operations that are common in object-oriented languages, but are not common in event processing languages. In these embodiments, an event processing system can access an extension language data cartridge to compile and execute queries that are written using a combination of the system's native event processing language and the extension language.

    摘要翻译: 一种用于使用本文中称为数据盒的一个或多个插件组件来扩展事件处理系统的能力的框架。 在一组实施例中,本文描述的数据盒架构可以使得事件处理系统能够支持与系统支持的本机事件处理语言不同的一个或多个扩展语言。 例如,可以提供某些“扩展语言”数据盒,其使得事件处理系统能够支持面向对象语言中常见的复杂数据类型和相关联的方法/操作,但在事件处理语言中不常见。 在这些实施例中,事件处理系统可以访问扩展语言数据盒,以编译和执行使用系统的本机事件处理语言和扩展语言的组合来编写的查询。

    METHOD TO CREATE A PARTITION-BY TIME/TUPLE-BASED WINDOW IN AN EVENT PROCESSING SERVICE
    2.
    发明申请
    METHOD TO CREATE A PARTITION-BY TIME/TUPLE-BASED WINDOW IN AN EVENT PROCESSING SERVICE 有权
    在事件处理服务中创建基于时间/基于TUPLE的窗口的方法

    公开(公告)号:US20080275891A1

    公开(公告)日:2008-11-06

    申请号:US11867471

    申请日:2007-10-04

    IPC分类号: G06F17/30

    CPC分类号: G06F17/30533

    摘要: A method to create a partition by time/tuple based window in an event processing service is provided. When continuous data streams are received, tuples are stored in a data structure with partitions based upon partition keys. Only a specified amount of tuples may be stored in each partition. When a partition exceeds the specified number of tuples, the oldest tuples are removed from the data structure. Tuples stored beyond a specified time period are also removed from the data structure. Two data structures may also be used to implement a time/tuple based window. Tuples are stored in both a data structure with a partition by window and a data structure with a range window. Tuples are removed in the partition by window when tuples exceed the amount in the partition. Tuples are removed in the range window when tuples exceed a specified time period. The two data structures are synchronized.

    摘要翻译: 提供了一种在事件处理服务中通过基于时间/元组的窗口创建分区的方法。 当连续数据流被接收时,元组被存储在具有基于分区键的分区的数据结构中。 每个分区中只能存储一定量的元组。 当分区超过指定数量的元组时,最旧的元组将从数据结构中删除。 存储超过指定时间段的元组也从数据结构中删除。 也可以使用两个数据结构来实现基于时间/元组的窗口。 元组被存储在具有分区的数据结构的窗口和具有范围窗口的数据结构中。 当元组超过分区中的数量时,元组在窗口中被删除。 当元组超过指定的时间段时,元组在范围窗口中被移除。 两个数据结构是同步的。

    Logging framework for a data stream processing server
    4.
    发明授权
    Logging framework for a data stream processing server 有权
    数据流处理服务器的日志框架

    公开(公告)号:US08527458B2

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

    申请号:US12534384

    申请日:2009-08-03

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

    CPC分类号: G06F17/30516 G06F17/30306

    摘要: 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.

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

    SPATIAL DATA CARTRIDGE FOR EVENT PROCESSING SYSTEMS
    5.
    发明申请
    SPATIAL DATA CARTRIDGE FOR EVENT PROCESSING SYSTEMS 有权
    用于事件处理系统的空间数据盒

    公开(公告)号:US20110161328A1

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

    申请号:US12949081

    申请日:2010-11-18

    IPC分类号: G06F17/30

    CPC分类号: G06F17/30241 G06F17/30516

    摘要: Techniques for extending the capabilities of an event processing system to support the processing of spatial data. In one set of embodiments, this extensibility can be provided via a plug-in extension component referred to herein as a spatial data cartridge. The spatial data cartridge can enable the event processing system to support spatial data types (e.g., point, polygon, etc.) and various operations related to such data types (e.g., proximity determinations, overlap determinations, etc.). The spatial data cartridge can also define an indexing scheme that can be integrated with the capabilities of the event processing system to support the indexing of spatial data. Using the spatial data cartridge, the event processing system can operate on spatial data even if spatial data formats are not natively supported by the system.

    摘要翻译: 用于扩展事件处理系统的能力以支持空间数据处理的技术。 在一组实施例中,可以通过本文称为空间数据盒的插件扩展组件来提供该可扩展性。 空间数据盒可以使得事件处理系统能够支持空间数据类型(例如,点,多边形等)和与这种数据类型相关的各种操作(例如,接近度确定,重叠确定等)。 空间数据盒还可以定义可与事件处理系统的能力集成以支持空间数据索引的索引方案。 使用空间数据盒,事件处理系统即使空间数据格式本身不被系统支持,也可以对空间数据进行操作。

    METHOD AND SYSTEM FOR SPILLING FROM A QUEUE TO A PERSISTENT STORE
    6.
    发明申请
    METHOD AND SYSTEM FOR SPILLING FROM A QUEUE TO A PERSISTENT STORE 有权
    从一个队列到一个存储商店的方法和系统

    公开(公告)号:US20100223437A1

    公开(公告)日:2010-09-02

    申请号:US12396008

    申请日:2009-03-02

    IPC分类号: G06F12/02

    CPC分类号: G06F12/12

    摘要: Techniques for managing memory usage of a processing system by spilling data from a memory to a persistent store based upon an evict policy are provided. A triggering event is detected. In response to the triggering event and based on the evict policy, it is determined whether data from the memory of the processing system is to be spilled to the persistent storage. The determination is made by comparing a level of free memory of the processing system with a threshold specified by the evict policy. The data is evicted from the memory.

    摘要翻译: 提供了用于通过基于逐出策略从存储器将数据溢出到持久存储器来管理处理系统的存储器使用的技术。 检测到触发事件。 响应于触发事件并且基于逐出策略,确定来自处理系统的存储器的数据是否将被溢出到持久存储器。 通过将处理系统的空闲内存的级别与逐出策略规定的阈值进行比较来确定。 数据从内存中逐出。

    Spatial data cartridge for event processing systems
    7.
    发明授权
    Spatial data cartridge for event processing systems 有权
    用于事件处理系统的空间数据盒式磁带

    公开(公告)号:US09430494B2

    公开(公告)日:2016-08-30

    申请号:US12949081

    申请日:2010-11-18

    IPC分类号: G06F17/30

    CPC分类号: G06F17/30241 G06F17/30516

    摘要: Techniques for extending the capabilities of an event processing system to support the processing of spatial data. In one set of embodiments, this extensibility can be provided via a plug-in extension component referred to herein as a spatial data cartridge. The spatial data cartridge can enable the event processing system to support spatial data types (e.g., point, polygon, etc.) and various operations related to such data types (e.g., proximity determinations, overlap determinations, etc.). The spatial data cartridge can also define an indexing scheme that can be integrated with the capabilities of the event processing system to support the indexing of spatial data. Using the spatial data cartridge, the event processing system can operate on spatial data even if spatial data formats are not natively supported by the system.

    摘要翻译: 用于扩展事件处理系统的能力以支持空间数据处理的技术。 在一组实施例中,可以通过本文称为空间数据盒的插件扩展组件来提供该可扩展性。 空间数据盒可以使得事件处理系统能够支持空间数据类型(例如,点,多边形等)和与这种数据类型相关的各种操作(例如,接近度确定,重叠确定等)。 空间数据盒还可以定义可与事件处理系统的能力集成以支持空间数据索引的索引方案。 使用空间数据盒,事件处理系统即使空间数据格式本身不被系统支持,也可以对空间数据进行操作。

    Method and system for aggregating the control of middleware control points
    8.
    发明申请
    Method and system for aggregating the control of middleware control points 有权
    集中控制中间件控制点的方法和系统

    公开(公告)号:US20060248233A1

    公开(公告)日:2006-11-02

    申请号:US11121820

    申请日:2005-05-02

    IPC分类号: G06F15/16

    CPC分类号: H04L41/12 H04L67/2838

    摘要: A method of aggregating control in a first network and a second network, the first network having first devices and the second network having second devices. A communication channel is established between the first and second networks; from the first network the second devices in the second network are discovered through the communication channel; and from the first network one of the second devices in the second network is controlled through the communication channel. The first and second network can be connected but isolated. Further, the first and second networks can implement different network protocols, or the same network protocol.

    摘要翻译: 一种在第一网络和第二网络中聚合控制的方法,所述第一网络具有第一设备,所述第二网络具有第二设备。 在第一和第二网络之间建立通信信道; 从第一网络通过通信信道发现第二网络中的第二设备; 并且从第一网络通过通信信道来控制第二网络中的第二设备之一。 第一个和第二个网络可以连接但是隔离。 此外,第一和第二网络可以实现不同的网络协议或相同的网络协议。

    Continuous query language (CQL) debugger in complex event processing (CEP)
    10.
    发明授权
    Continuous query language (CQL) debugger in complex event processing (CEP) 有权
    复杂事件处理(CEP)中的连续查询语言(CQL)调试器

    公开(公告)号:US09329975B2

    公开(公告)日:2016-05-03

    申请号:US13177748

    申请日:2011-07-07

    IPC分类号: G06F9/44 G06F11/36 G06F11/32

    摘要: A method including receiving, at a computer system, debugging configuration information specifying a functional area of a data stream processing server to be debugged, is described. Furthermore, the method includes identifying, by the computer system, an object associated with the functional area that has been instantiated by the data stream processing server, determining, by the computer system, that tracing for the object is enabled to perform the debugging, and instantiating, by the computer system, a tracelet associated with the object. Further, the method includes stepping, by the computer system, through the tracelet associated with the object to debug the object, and displaying, by the computer system, a visual representation of debugging results associated with the object.

    摘要翻译: 描述了在计算机系统处接收指定要调试的数据流处理服务器的功能区域的调试配置信息的方法。 此外,该方法包括由计算机系统识别由数​​据流处理服务器实例化的与功能区域相关联的对象,由计算机系统确定能够进行对该对象的跟踪以进行调试,以及 由计算机系统实例化与对象相关联的跟踪。 此外,该方法包括通过计算机系统通过与对象相关联的跟踪步骤来调试对象,并且由计算机系统显示与对象相关联的调试结果的可视表示。