公开(公告)号：US20110270879A1

公开(公告)日：2011-11-03

申请号：US13184528

申请日：2011-07-16

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

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

IPC分类号： G06F17/30

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

摘要： A computer is programmed to accept a command to create a new aggregation defined by a user during execution of continuous queries on streams of data. The computer is further programmed to thereafter accept and process new continuous queries using the new aggregation, in a manner similar to built-in aggregations. The user typically writes a set of instructions to perform the new aggregation, and identifies in the command, a location of the set of instructions. In response to such a command, the computer creates metadata identifying the new aggregation. The metadata is used to instantiate one aggregation for each group of data in a current window, grouped by an attribute identified in a new query.

摘要翻译： 计算机被编程为接受命令以在对数据流的连续查询执行期间创建由用户定义的新聚合。 该计算机被进一步编程为此后以类似于内置聚合的方式接受和处理使用新聚合的新的连续查询。 用户通常写一组指令来执行新的聚合，并且在命令中标识该组指令的位置。 响应于这样的命令，计算机创建标识新聚合的元数据。 元数据用于为当前窗口中的每组数据实例化一个聚合，按照新查询中标识的属性进行分组。

公开(公告)号：US07996388B2

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

申请号：US11874202

申请日：2007-10-17

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

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

IPC分类号： G06F17/30

CPC分类号： G06F17/30516

摘要： A new continuous query to a data stream management system (DSMS) may use a stream or a relation which may or may not be used by continuous queries previously registered in the DSMS. The DSMS is programmed to modify an execution plan to accommodate execution of the new query while continuing to execute the previously registered continuous queries. The modified execution plan may include new operators and/or share existing operators. The DSMS is programmed to cause operators which output a relation to propagate a current state of the relation to each newly-coupled operator that uses the relation. The current state is propagated only to operators that have been newly coupled and have thus not yet received any state information previously. After propagation of current state to newly-coupled operators, results of processing any new data for the relation are supplied to all operators coupled thereto, including newly-coupled operators and existing operators.

摘要翻译： 对数据流管理系统（DSMS）的新的连续查询可以使用可以或可能不被先前在DSMS中注册的连续查询使用的流或关系。 DSMS被编程为修改执行计划以适应新查询的执行，同时继续执行先前注册的连续查询。 修改的执行计划可以包括新的运营商和/或共享现有运营商。 DSMS被编程为使得输出关系的操作者将关系的当前状态传播到使用该关系的每个新耦合的运算符。 当前状态仅传播到已经新耦合的操作符，并且因此以前尚未接收到任何状态信息。 在将当前状态传播到新耦合的运营商之后，将与关联关系的任何新数据进行处理的结果提供给所有与之耦合的运营商，包括新耦合运营商和现有运营商。

公开(公告)号：US07984040B2

公开(公告)日：2011-07-19

申请号：US12133899

申请日：2008-06-05

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

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

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

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

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

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

公开(公告)号：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与事件处理服务器进行通信。

公开(公告)号：US07809675B2

公开(公告)日：2010-10-05

申请号：US11172472

申请日：2005-06-29

申请人： Namit Jain ,  Syam Pannala ,  Sam Idicula ,  Nipun Agarwal ,  Eric Sedlar ,  Vikram Kapoor

发明人： Namit Jain ,  Syam Pannala ,  Sam Idicula ,  Nipun Agarwal ,  Eric Sedlar ,  Vikram Kapoor

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

CPC分类号： G06F17/30171 ,  G06F17/30233 ,  Y10S707/99931 ,  Y10S707/99942 ,  Y10S707/99943

摘要： A method and apparatus for sharing state information among a plurality of servers is provided. A first server receives a request to perform a file operation, such as a NFS file system operation. Thereafter, the first server updates state information to reflect a change in state associated with processing the request. The first server then causes state update information, which identifies the change in state that was made at the first server, to be propagated to a second server. The second server updates state information, stored at the second server, to reflect the change in state associated with processing the request at the first server. Advantageously, a client may send a series of stateful file operations to either the first server or the second server, even if processing any one of the stateful file operation requests requires knowledge of the state of processing prior requests in the series of requests.

摘要翻译： 提供了一种用于在多个服务器之间共享状态信息的方法和装置。 第一服务器接收执行诸如NFS文件系统操作之类的文件操作的请求。 此后，第一服务器更新状态信息以反映与处理请求相关联的状态变化。 然后，第一服务器导致状态更新信息，其标识在第一服务器处进行的状态的改变，以被传播到第二服务器。 第二服务器更新存储在第二服务器处的状态信息，以反映与在第一服务器处理请求相关联的状态变化。 有利地，客户机可以向第一服务器或第二服务器发送一系列有状态的文件操作，即使处理有状态文件操作请求中的任何一个需要知道在一系列请求中处理先前请求的状态。

公开(公告)号：US07739265B2

公开(公告)日：2010-06-15

申请号：US11874850

申请日：2007-10-18

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

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

IPC分类号： G06F17/30

CPC分类号： G06F17/30516

摘要： A first continuous query is deleted from several continuous queries that are being executed, by performing different actions that depend on how resources are shared therebetween. As an example, a second continuous query is deleted if a view is referenced by the first continuous query, and if the view is built on the second continuous query, and if the view is not referenced by any query other than the first continuous query. Such deletion is followed by compiling the second continuous query, followed by updating the view to refer to a newly-compiled version of the second continuous query. As another example, if an operator in the first continuous query is not used by any other query, this operator is de-scheduled from execution, and any exclusively-owned resources are released. Also, data to be read by the operator and data generated by the operator, if present in shared resources, are deleted therefrom.

摘要翻译： 通过执行取决于资源如何共享的不同动作，从正在执行的几个连续查询中删除第一个连续查询。 作为示例，如果第一连续查询引用了视图，并且视图是建立在第二连续查询上，并且视图没有被第一连续查询之外的任何查询引用，则删除第二连续查询。 这样的删除之后是编译第二连续查询，随后更新视图以引用第二连续查询的新编译版本。 作为另一示例，如果第一连续查询中的运算符不被任何其他查询使用，则该运算符从执行中去调度，并且释放任何专有资源。 此外，由用户读取的数据和由运营商产生的数据（如果存在于共享资源中）将被删除。

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

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

公开(公告)号：US20090106190A1

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

申请号：US11874896

申请日：2007-10-18

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

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

IPC分类号： G06F17/30

CPC分类号： G06F8/20

摘要： A data stream management system (DSMS) is designed to support a new user-defined function, by creating and using at least two structures as follows. A first structure (“metadata entry”) is created in response to a command for creation of the new function, and maps a single instance of a class to the function's name. A second structure is created with creation of an operator on receipt of each new continuous query that uses the new function. The second structure (“operator specific data structure”) contains a path to the newly-created instance, which path is obtained by looking up the first structure. Additional second structures are created on receipt of additional continuous queries which use the new function, but all second structures contain the same path. All continuous queries use the same instance. Repeated use of a single instance to compile and execute multiple queries eliminates repeated instantiation of the same function.

摘要翻译： 数据流管理系统（DSMS）旨在通过如下创建和使用至少两个结构来支持新的用户定义的功能。 响应于用于创建新功能的命令创建第一个结构（“元数据条目”），并将类的单个实例映射到函数的名称。 在接收到使用新功能的每个新的连续查询时，创建第二个结构。 第二个结构（“运算符特定数据结构”）包含新创建的实例的路径，通过查找第一个结构获取哪个路径。 附加的第二个结构是在接收到使用新功能的附加连续查询时创建的，但所有第二个结构都包含相同的路径。 所有连续查询使用相同的实例。 重复使用单个实例来编译和执行多个查询消除了相同功能的重复实例化。

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

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