Finer grained point-to-point event propagation
    61.
    发明授权
    Finer grained point-to-point event propagation 有权
    更精细的点对点事件传播

    公开(公告)号:US07725902B2

    公开(公告)日:2010-05-25

    申请号:US11224918

    申请日:2005-09-12

    IPC分类号: G06F13/00

    摘要: A method and apparatus for propagating and managing data, transactions and events either within a database, or from one database to another is provided. In one embodiment, messages are propagated from a source to a first queue and a second queue with the queues associated with the same database. The connection from the source to each queue maintains its own propagation job. This method could also be employed with cluster databases.

    摘要翻译: 提供了一种用于在数据库内或从一个数据库到另一个数据库中传播和管理数据,事务和事件的方法和装置。 在一个实施例中,消息从源传播到第一队列,并且具有与同一数据库相关联的队列的第二队列。 从源到每个队列的连接保持自己的传播作业。 这种方法也可以用于集群数据库。

    Buffered message queue architecture for database management systems with unlimited buffered message queue with limited shared memory
    63.
    发明授权
    Buffered message queue architecture for database management systems with unlimited buffered message queue with limited shared memory 有权
    具有无限缓冲消息队列的数据库管理系统的缓冲消息队列架构,具有有限的共享内存

    公开(公告)号:US07185033B2

    公开(公告)日:2007-02-27

    申请号:US10443175

    申请日:2003-05-21

    IPC分类号: G06F17/30

    摘要: A buffered message queue architecture for managing messages in a database management system is disclosed. A “buffered message queue” refers to a message queue implemented in a volatile memory, such as a RAM. The volatile memory may be a shared volatile memory that is accessible by a plurality of processes. The buffered message queue architecture supports a publish and subscribe communication mechanism, where the message producers and message consumers may be decoupled from and independent of each other. The buffered message queue architecture provides all the functionality of a persistent publish-subscriber messaging system, without ever having to store the messages in persistent storage. The buffered message queue architecture provides better performance and scalability since no persistent operations are needed and no UNDO/REDO logs need to be maintained. Messages published to the buffered message queue are delivered to all eligible subscribers at least once, even in the event of failures, as long as the application is “repeatable.” The buffered message queue architecture also includes management mechanisms for performing buffered message queue cleanup and also for providing unlimited size buffered message queues when limited amounts of shared memory are available. The architecture also includes “zero copy” buffered message queues and provides for transaction-based enqueue of messages.

    摘要翻译: 公开了一种用于管理数据库管理系统中的消息的缓冲消息队列架构。 “缓冲消息队列”是指在诸如RAM的易失性存储器中实现的消息队列。 易失性存储器可以是可由多个进程访问的共享易失性存储器。 缓冲消息队列架构支持发布和订阅通信机制,消息生成器和消息消费者可以彼此分离并且彼此独立。 缓冲消息队列体系结构提供了持久性发布 - 订阅者消息系统的所有功能,而无需将消息存储在持久存储中。 缓冲消息队列架构提供更好的性能和可扩展性,因为不需要持续的操作,并且不需要维护UNDO / REDO日志。 只要应用程序是“可重复的”,发布到缓冲消息队列的消息至少发送一次,即使发生故障。 缓冲消息队列架构还包括用于执行缓冲消息队列清理的管理机制,并且还用于当有限量的共享存储器可用时提供无限大小的缓冲消息队列。 该架构还包括“零拷贝”缓冲消息队列,并提供基于事务的消息队列。

    Database management system for implementing independent database actions in response to events of interest
    64.
    发明授权
    Database management system for implementing independent database actions in response to events of interest 有权
    数据库管理系统,用于针对感兴趣的事件实施独立数据库操作

    公开(公告)号:US07089265B1

    公开(公告)日:2006-08-08

    申请号:US10124908

    申请日:2002-04-17

    IPC分类号: G06F17/30

    摘要: A method and apparatus for managing a database is provided. A database management system conducts a plurality of database transactions with a plurality of clients. An event may be detected as a result of one of the transactions. The event is mapped to an independent database action. In response to detecting the event, the independent database action is executed without interference from the transaction that caused the event.

    摘要翻译: 提供了一种用于管理数据库的方法和装置。 数据库管理系统与多个客户端进行多个数据库事务。 作为其中一个交易的结果可能会检测到一个事件。 事件映射到独立的数据库操作。 响应于检测到事件,独立数据库动作被执行而不受造成事件的事务的干扰。

    Techniques for matching a certain class of regular expression-based patterns in data streams
    65.
    发明授权
    Techniques for matching a certain class of regular expression-based patterns in data streams 有权
    在数据流中匹配某类基于正则表达式的模式的技术

    公开(公告)号:US08498956B2

    公开(公告)日:2013-07-30

    申请号:US12548209

    申请日:2009-08-26

    IPC分类号: G06N5/00

    CPC分类号: G06K9/62

    摘要: Techniques for detecting patterns in data streams. A pattern to be detected may be specified using a regular expression. Events received in data streams are then processed during runtime to detect occurrences of the pattern specified by the regular expression in the data stream. If the pattern to be matched belongs to a certain predetermined class of patterns, then a pattern matching technique that is customized for that class of patterns is used during the runtime events processing.

    摘要翻译: 用于检测数据流中的模式的技术。 可以使用正则表达式来指定要检测的模式。 然后在运行时处理在数据流中收到的事件,以检测数据流中正则表达式指定的模式的出现。 如果要匹配的模式属于某种预定类型的模式,则在运行时事件处理期间使用针对该类模式定制的模式匹配技术。

    Extensibility platform using data cartridges
    66.
    发明授权
    Extensibility platform using data cartridges 有权
    扩展性平台使用数据盒式磁带

    公开(公告)号:US08447744B2

    公开(公告)日:2013-05-21

    申请号:US12957194

    申请日:2010-11-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. Generally speaking, a data cartridge is a self-contained unit of data that can be registered with an event processing system and can store information pertaining to one or more objects (referred to herein as extensible objects) that are not natively supported by the system. Examples of such extensible objects can include data types, functions, indexes, data sources, and others. By interacting with a data cartridge, an event processing system can compile and execute queries that reference extensible objects defined in the data cartridge, thereby extending the system beyond its native capabilities.

    摘要翻译: 一种用于使用本文中称为数据盒的一个或多个插件组件来扩展事件处理系统的能力的框架。 一般来说,数据盒式磁带是能够向事件处理系统注册的独立的数据单元,并且可以存储与系统本身不支持的一个或多个对象(这里称为可扩展对象)有关的信息。 这种可扩展对象的示例可以包括数据类型,函数,索引,数据源等。 通过与数据盒进行交互,事件处理系统可以编译和执行引用在数据盒中定义的可扩展对象的查询,从而将系统扩展到其本机能力之外。

    Publisher flow control and bounded guaranteed delivery for message queues
    67.
    发明授权
    Publisher flow control and bounded guaranteed delivery for message queues 有权
    发布者流控制和消息队列的有限保证传递

    公开(公告)号:US08397244B2

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

    申请号:US12835726

    申请日:2010-07-13

    IPC分类号: G06F9/44

    CPC分类号: G06F9/546

    摘要: Techniques for managing messages in computer systems are provided. In one embodiment, in response to a publisher attempting to enqueue a message in a queue, a determination is made whether a condition is satisfied. The condition is based on the current usage of the queue by the publisher. Based on whether the condition is satisfied, a decision is made whether to enqueue the message in the queue. The decision whether to enqueue the message may comprise restricting the publisher from enqueueing any more messages in the queue until the same or a different condition is satisfied.

    摘要翻译: 提供了在计算机系统中管理消息的技术。 在一个实施例中,响应于发布者尝试在队列中排队消息,确定是否满足条件。 条件是基于发布者当前使用的队列。 根据条件是否满足,决定是否将队列中的消息排队。 是否排入消息的决定可能包括限制发布者排队队列中的任何更多消息,直到满足相同或不同的条件。

    Infrastructure for spilling pages to a persistent store
    68.
    发明授权
    Infrastructure for spilling pages to a persistent store 有权
    将页面溢出到持久存储的基础设施

    公开(公告)号:US08352517B2

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

    申请号:US12395871

    申请日:2009-03-02

    IPC分类号: G06F17/00

    CPC分类号: G06F17/30463 G06F17/30471

    摘要: Techniques for managing memory usage in a processing system are provided. This may be achieved by receiving a data stream including multiple tuples and determining a query plan that was generated for a continuous query applied to the multiple tuples in the data stream. The query plan may include one or more operators. Before scheduling an operator in the query plan, it is determined when an eviction is to be performed based a level of free memory of the processing system. An eviction candidate is determined and a page associated with the eviction candidate is evicted from the memory to a persistent storage.

    摘要翻译: 提供了用于管理处理系统中的存储器使用的技术。 这可以通过接收包括多个元组的数据流并且确定为应用于数据流中的多个元组的连续查询而生成的查询计划来实现。 查询计划可以包括一个或多个运算符。 在调度查询计划中的运算符之前,确定何时根据处理系统的空闲内存的级别执行逐出。 确定驱逐候选人,并且与驱逐候选人相关联的页面从存储器逐出到永久存储器。

    Method and system for spilling from a queue to a persistent store
    70.
    发明授权
    Method and system for spilling from a queue to a persistent store 有权
    从队列溢出到持久存储的方法和系统

    公开(公告)号:US08145859B2

    公开(公告)日:2012-03-27

    申请号: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.

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