公开(公告)号：US07185034B2

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

申请号：US10443323

申请日：2003-05-21

申请人： Namit Jain ,  Neerja Bhatt ,  Kapil Surlaker ,  Krishnan Meiyyappan ,  Shailendra Mishra ,  Bhagat Nainani

发明人： Namit Jain ,  Neerja Bhatt ,  Kapil Surlaker ,  Krishnan Meiyyappan ,  Shailendra Mishra ,  Bhagat Nainani

IPC分类号： G06F17/30

CPC分类号： G06F17/30289 ,  Y10S707/99957

摘要： 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日志。 只要应用程序是“可重复的”，发布到缓冲消息队列的消息至少发送一次，即使发生故障。 缓冲消息队列架构还包括用于执行缓冲消息队列清理的管理机制，并且还用于当有限量的共享存储器可用时提供无限大小的缓冲消息队列。 该架构还包括“零拷贝”缓冲消息队列，并提供基于事务的消息队列。

公开(公告)号：US07181482B2

公开(公告)日：2007-02-20

申请号：US10443206

申请日：2003-05-21

申请人： Namit Jain ,  Neerja Bhatt ,  Kapil Surlaker ,  Krishnan Meiyyappan ,  Sanjay Kaluskar ,  Shailendra Mishra

发明人： Namit Jain ,  Neerja Bhatt ,  Kapil Surlaker ,  Krishnan Meiyyappan ,  Sanjay Kaluskar ,  Shailendra Mishra

IPC分类号： G06F17/30

CPC分类号： G06F17/30289 ,  Y10S707/99931 ,  Y10S707/99957

摘要： 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日志。 只要应用程序是“可重复的”，发布到缓冲消息队列的消息至少发送一次，即使发生故障。 缓冲消息队列架构还包括用于执行缓冲消息队列清理的管理机制，并且还用于当有限量的共享存储器可用时提供无限大小的缓冲消息队列。 该架构还包括“零拷贝”缓冲消息队列，并提供基于事务的消息队列。

公开(公告)号：US20060015565A1

公开(公告)日：2006-01-19

申请号：US11213191

申请日：2005-08-25

申请人： Bhagat Nainani ,  Neerja Bhatt ,  Shailendra Mishra ,  Krishnan Meiyyappan ,  Namit Jain ,  Wei Wang

发明人： Bhagat Nainani ,  Neerja Bhatt ,  Shailendra Mishra ,  Krishnan Meiyyappan ,  Namit Jain ,  Wei Wang

IPC分类号： G06F15/16

CPC分类号： H04L67/02 ,  H04L67/327

摘要： One embodiment of the present invention provides a system that facilitates accessing communication queues using a public network. The system operates by first generating a message or messages at a client. The system then formats these messages in a publicly available format. Next, the system communicates the messages across the public network to a web server. The web server receives the messages and transforms the messages to a database specific format. The web server then passes the messages to a queue within a database server across a proprietary network. In one embodiment of the present invention, the system includes queue-to-queue propagation with exactly once guarantees and recovery from failures. In one embodiment of the present invention, the system includes transactional guarantees when a client accesses a queue.

摘要翻译： 本发明的一个实施例提供一种便于使用公共网络访问通信队列的系统。 系统首先在客户端生成消息或消息。 然后，系统以公开可用的格式来格式化这些消息。 接下来，系统通过公共网络将消息传送到web服务器。 Web服务器接收消息并将消息转换为数据库特定格式。 然后，Web服务器通过专有网络将消息传递到数据库服务器内的队列。 在本发明的一个实施例中，系统包括具有一次保证的队列到队列传播和从故障恢复。 在本发明的一个实施例中，当客户端访问队列时，系统包括事务保证。

公开(公告)号：US07185033B2

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

申请号：US10443175

申请日：2003-05-21

申请人： Namit Jain ,  Neerja Bhatt ,  Kapil Surlaker ,  Krishnan Meiyyappan ,  Shailendra Mishra

发明人： Namit Jain ,  Neerja Bhatt ,  Kapil Surlaker ,  Krishnan Meiyyappan ,  Shailendra Mishra

IPC分类号： G06F17/30

CPC分类号： G06F9/546 ,  G06F11/1471 ,  G06F11/1474 ,  G06F17/30289 ,  G06F2201/80 ,  Y10S707/99957

摘要： 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日志。 只要应用程序是“可重复的”，发布到缓冲消息队列的消息至少发送一次，即使发生故障。 缓冲消息队列架构还包括用于执行缓冲消息队列清理的管理机制，并且还用于当有限量的共享存储器可用时提供无限大小的缓冲消息队列。 该架构还包括“零拷贝”缓冲消息队列，并提供基于事务的消息队列。

公开(公告)号：US07203706B2

公开(公告)日：2007-04-10

申请号：US10443207

申请日：2003-05-21

申请人： Namit Jain ,  Neerja Bhatt ,  Kapil Surlaker ,  Krishnan Meiyyappan ,  Shailendra Mishra

发明人： Namit Jain ,  Neerja Bhatt ,  Kapil Surlaker ,  Krishnan Meiyyappan ,  Shailendra Mishra

IPC分类号： G06F17/30

CPC分类号： G06F9/544 ,  G06F17/30371 ,  Y10S707/99942 ,  Y10S707/99943 ,  Y10S707/99944 ,  Y10S707/99945 ,  Y10S707/99948

摘要： 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日志。 只要应用程序是“可重复的”，发布到缓冲消息队列的消息至少发送一次，即使发生故障。 缓冲消息队列架构还包括用于执行缓冲消息队列清理的管理机制，并且还用于当有限量的共享存储器可用时提供无限大小的缓冲消息队列。 该架构还包括“零拷贝”缓冲消息队列，并提供基于事务的消息队列。

公开(公告)号：US07206842B2

公开(公告)日：2007-04-17

申请号：US11213191

申请日：2005-08-25

申请人： Bhagat V. Nainani ,  Neerja Bhatt ,  Shailendra K. Mishra ,  Krishnan Meiyyappan ,  Namit Jain ,  Wei Wang

发明人： Bhagat V. Nainani ,  Neerja Bhatt ,  Shailendra K. Mishra ,  Krishnan Meiyyappan ,  Namit Jain ,  Wei Wang

IPC分类号： G06F15/173

CPC分类号： H04L67/02 ,  H04L67/327

摘要： One embodiment of the present invention provides a system that facilitates accessing communication queues using a public network. The system operates by first generating a message or messages at a client. The system then formats these messages in a publicly available format. Next, the system communicates the messages across the public network to a web server. The web server receives the messages and transforms the messages to a database specific format. The web server then passes the messages to a queue within a database server across a proprietary network. In one embodiment of the present invention, the system includes queue-to-queue propagation with exactly once guarantees and recovery from failures. In one embodiment of the present invention, the system includes transactional guarantees when a client accesses a queue.

摘要翻译： 本发明的一个实施例提供一种便于使用公共网络访问通信队列的系统。 系统首先在客户端生成消息或消息。 然后，系统以公开可用的格式来格式化这些消息。 接下来，系统通过公共网络将消息传送到web服务器。 Web服务器接收消息并将消息转换为数据库特定格式。 然后，Web服务器通过专有网络将消息传递到数据库服务器内的队列。 在本发明的一个实施例中，系统包括具有一次保证的队列到队列传播和从故障恢复。 在本发明的一个实施例中，当客户端访问队列时，系统包括事务保证。

公开(公告)号：US06978305B1

公开(公告)日：2005-12-20

申请号：US10027100

申请日：2001-12-19

申请人： Bhagat V. Nainani ,  Neerja Bhatt ,  Shailendra K. Mishra ,  Krishnan Meiyyappan ,  Namit Jain ,  Wei Wang

发明人： Bhagat V. Nainani ,  Neerja Bhatt ,  Shailendra K. Mishra ,  Krishnan Meiyyappan ,  Namit Jain ,  Wei Wang

IPC分类号： G06F15/173 ,  H04L29/08

CPC分类号： H04L67/02 ,  H04L67/327

摘要： One embodiment of the present invention provides a system that facilitates accessing communication queues using a public network. The system operates by first generating a message or messages at a client. The system then formats these messages in a publicly available format. Next, the system communicates the messages across the public network to a web server. The web server receives the messages and transforms the messages to a database specific format. The web server then passes the messages to a queue within a database server across a proprietary network. In one embodiment of the present invention, the system includes queue-to-queue propagation with exactly once guarantees and recovery from failures. In one embodiment of the present invention, the system includes transactional guarantees when a client accesses a queue.

摘要翻译： 本发明的一个实施例提供一种便于使用公共网络访问通信队列的系统。 系统首先在客户端生成消息或消息。 然后，系统以公开可用的格式来格式化这些消息。 接下来，系统通过公共网络将消息传送到web服务器。 Web服务器接收消息并将消息转换为数据库特定格式。 然后，Web服务器通过专有网络将消息传递到数据库服务器内的队列。 在本发明的一个实施例中，系统包括具有一次保证的队列到队列传播和从故障恢复。 在本发明的一个实施例中，当客户端访问队列时，系统包括事务保证。

公开(公告)号：US09305238B2

公开(公告)日：2016-04-05

申请号：US12548187

申请日：2009-08-26

申请人： Anand Srinivasan ,  Rakesh Komuravelli ,  Namit Jain ,  Shailendra Mishra

发明人： Anand Srinivasan ,  Rakesh Komuravelli ,  Namit Jain ,  Shailendra Mishra

IPC分类号： G06F17/30 ,  G06K9/62

CPC分类号： G06K9/62

摘要： Techniques for detecting patterns in one or more data or event streams. A pattern to be detected may be specified using a regular expression. Events received in a data stream are processed during runtime to detect occurrences of the specified pattern in the data stream. In one embodiment, a pattern type or class is determined for the specified pattern and pattern matching is performed using a technique selected based upon the type or class determined for the specified pattern.

摘要翻译： 用于检测一个或多个数据或事件流中的模式的技术。 可以使用正则表达式来指定要检测的模式。 在运行期间处理在数据流中接收的事件，以检测数据流中指定模式的出现。 在一个实施例中，对于指定的图案确定图案类型或类别，并且使用基于为指定图案确定的类型或类别而选择的技术来执行图案匹配。

公开(公告)号：US08387076B2

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

申请号：US12506905

申请日：2009-07-21

申请人： Mohit Thatte ,  Sandeep Bishnoi ,  Namit Jain ,  Anand Srinivasan ,  Shailendra Mishra

发明人： Mohit Thatte ,  Sandeep Bishnoi ,  Namit Jain ,  Anand Srinivasan ,  Shailendra Mishra

IPC分类号： G06F9/46 ,  G06F17/30

CPC分类号： G06F17/3056 ,  G06F9/541

摘要： Techniques for facilitating communication between one or more client applications and an event processing server. In one set of embodiments, a framework is provided that enables a client application to communicate with an event processing server via a standard database connectivity API, such as Java Database Connectivity (JDBC).

摘要翻译： 用于促进一个或多个客户端应用与事件处理服务器之间的通信的技术。 在一组实施例中，提供了一种框架，其使得客户端应用程序能够通过诸如Java数据库连接（JDBC）的标准数据库连接API与事件处理服务器进行通信。

公开(公告)号：US08019747B2

公开(公告)日：2011-09-13

申请号：US11927681

申请日：2007-10-30

申请人： Anand Srinivasan ,  Namit Jain ,  Parul Jain ,  Shailendra Mishra

发明人： Anand Srinivasan ,  Namit Jain ,  Parul Jain ,  Shailendra Mishra

IPC分类号： G06F17/30

CPC分类号： G06F17/30964

摘要： Facilitating flexible windows in querying continuous data streams. In one embodiment, a software code is associated with a window, wherein execution of the software code determines the values to be included in the window. On receiving a query indicating the window, the result of the query is generated based on the values in the window determined by execution of the software code. The software code may be identified by an identifier and thus used for different queries on the same or different continuous data streams.

摘要翻译： 方便灵活的窗口查询连续的数据流。 在一个实施例中，软件代码与窗口相关联，其中软件代码的执行确定要包括在窗口中的值。 在接收到指示窗口的查询时，基于通过执行软件代码确定的窗口中的值来生成查询结果。 软件代码可以由标识符标识，并且因此用于相同或不同连续数据流上的不同查询。