公开(公告)号：US20110022618A1

公开(公告)日：2011-01-27

申请号：US12506891

申请日：2009-07-21

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

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

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

CPC分类号： G06F17/30516 ,  G06F9/541 ,  H04L29/00

摘要： 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与事件处理服务器进行通信。

公开(公告)号：US20090112803A1

公开(公告)日：2009-04-30

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

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

公开(公告)号：US20090037370A1

公开(公告)日：2009-02-05

申请号：US12133899

申请日：2008-06-05

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

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

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

CPC分类号： G06F17/30516 ,  G06F17/30545

摘要： Methods and systems for distributed event processing are disclosed. In one embodiment, a system for distributed event processing includes a first event processor and a second event processor. The first event processor receives event data associated with an event stream. The second event processor receives a query associated with the event stream. A request to the first event processor is generated by the second event processor based on the query for a first portion of event data associated with the event stream. The second event processor receives the first portion of event data from the first event processor. The second event processor then generates an event based on the first portion of event data.

摘要翻译： 公开了分布式事件处理的方法和系统。 在一个实施例中，用于分布式事件处理的系统包括第一事件处理器和第二事件处理器。 第一事件处理器接收与事件流相关联的事件数据。 第二事件处理器接收与事件流相关联的查询。 基于对与事件流相关联的事件数据的第一部分的查询，由第二事件处理器生成对第一事件处理器的请求。 第二事件处理器从第一事件处理器接收事件数据的第一部分。 然后，第二事件处理器基于事件数据的第一部分生成事件。

公开(公告)号：US20080275891A1

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

申请号：US11867471

申请日：2007-10-04

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

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

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.

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

公开(公告)号：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.

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

公开(公告)号：US07089265B1

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

申请号：US10124908

申请日：2002-04-17

申请人： Namit Jain ,  Rajit Kambo ,  Shailendra Mishra

发明人： Namit Jain ,  Rajit Kambo ,  Shailendra Mishra

IPC分类号： G06F17/30

CPC分类号： G06F17/30368 ,  Y10S707/99943 ,  Y10S707/99945

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

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

公开(公告)号：US08498956B2

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

申请号：US12548209

申请日：2009-08-26

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

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

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.

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