公开(公告)号：US20070061380A1

公开(公告)日：2007-03-15

申请号：US11224918

申请日：2005-09-12

申请人： Krishnan Meiyyappan ,  Ramkumar Venkatesan ,  Shailendra Mishra

发明人： Krishnan Meiyyappan ,  Ramkumar Venkatesan ,  Shailendra Mishra

IPC分类号： G06F17/30

CPC分类号： G06F9/542 ,  G06F9/544 ,  G06F2209/544

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

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

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

公开(公告)号：US11442847B2

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

申请号：US17151288

申请日：2021-01-18

申请人： Saibalesh Mukhopadhyay ,  Shailendra Mishra

发明人： Saibalesh Mukhopadhyay ,  Shailendra Mishra

IPC分类号： G06F11/36 ,  G06F11/30 ,  G06F11/34

摘要： Systems and methods are disclosed that determine a duration and resources for testing software. In some implementations, the system performs operations including determining functions performed by applications of the software product, and determining categories based on the functions, the categories including a lowest-criticality category and a highest-criticality category. The operations also include determining degrees of change to the applications and test scripts corresponding to the degrees of change. The operations also include generating a data structure based on the categories and the degrees of change, the data structure including columns identifying the categories in an order from lowest to highest criticality. The operations also include determining weights corresponding to distances of the categories from the highest-criticality category. The operations also include determining a set of test scripts based on the weights, the test scripts, and the degree of change indicators, and determining the resources based on the set of test scripts.

公开(公告)号：US09058360B2

公开(公告)日：2015-06-16

申请号：US12957201

申请日：2010-11-30

申请人： Alexandre de Castro Alves ,  Anand Srinivasan ,  Hoyong Park ,  Shailendra Mishra

发明人： Alexandre de Castro Alves ,  Anand Srinivasan ,  Hoyong Park ,  Shailendra Mishra

IPC分类号： G06F17/30 ,  G06F7/00

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.

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

公开(公告)号：US08935293B2

公开(公告)日：2015-01-13

申请号：US12396464

申请日：2009-03-02

申请人： Hoyong Park ,  Namit Jain ,  Anand Srinivasan ,  Shailendra Mishra

发明人： Hoyong Park ,  Namit Jain ,  Anand Srinivasan ,  Shailendra Mishra

IPC分类号： G06F7/00 ,  G06F17/30 ,  G06F9/445 ,  G06F9/455

CPC分类号： G06F9/44521 ,  G06F9/45504

摘要： Techniques for reducing the memory used for processing events received in a data stream are provided. This may be achieved by reducing the memory required for storing tuples. A method for processing a data stream includes receiving a tuple and determining a tuple specification that defines a layout of the tuple. The layout identifies one or more data types that are included in the tuple. A tuple class corresponding to the tuple specification may be determined. A tuple object based on the tuple class is instantiated, and during runtime of the processing system. The tuple object is stored in a memory.

摘要翻译： 提供了用于减少用于处理在数据流中接收的事件的存储器的技术。 这可以通过减少存储元组所需的内存来实现。 一种用于处理数据流的方法包括接收元组并确定定义元组的布局的元组规范。 布局标识包含在元组中的一个或多个数据类型。 可以确定对应于元组规范的元组类。 基于元组类的元组对象被实例化，并且在处理系统的运行期间。 元组对象存储在内存中。

公开(公告)号：US08589436B2

公开(公告)日：2013-11-19

申请号：US12548222

申请日：2009-08-26

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

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

IPC分类号： G06F17/30

CPC分类号： G06K9/62

摘要： Techniques for detecting patterns in one or more data 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.

摘要翻译： 用于检测一个或多个数据流中的模式的技术。 可以使用正则表达式来指定要检测的模式。 在运行期间处理在数据流中接收的事件，以检测数据流中指定模式的出现。

公开(公告)号：US08386466B2

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

申请号：US12534398

申请日：2009-08-03

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

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

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.

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

公开(公告)号：US08103655B2

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

申请号：US11927683

申请日：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

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

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

公开(公告)号：US20110161321A1

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

申请号：US12957194

申请日：2010-11-30

申请人： Alexandre de Castro Alves ,  Anand Srinivasan ,  Hoyong Park ,  Shailendra Mishra

发明人： Alexandre de Castro Alves ,  Anand Srinivasan ,  Hoyong Park ,  Shailendra Mishra

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. 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.

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

公开(公告)号：US20100281491A1

公开(公告)日：2010-11-04

申请号：US12835726

申请日：2010-07-13

申请人： Kapil Surlaker ,  Neerja Bhatt ,  Shailendra Mishra

发明人： Kapil Surlaker ,  Neerja Bhatt ,  Shailendra Mishra

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.

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