公开(公告)号：US20110246445A1

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

申请号：US13162882

申请日：2011-06-17

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

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

公开(公告)号：US20100223437A1

公开(公告)日：2010-09-02

申请号：US12396008

申请日：2009-03-02

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

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

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.

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

公开(公告)号：US20090112802A1

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

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

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

公开(公告)号：US20090100029A1

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

申请号：US11873407

申请日：2007-10-16

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

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

IPC分类号： G06F7/00 ,  G06F15/16

CPC分类号： G06F17/30548

摘要： A new continuous query to a data stream management system (DSMS) may use a silent relation whose source does not provide any heartbeats. During execution of any given operator, the DSMS processes data from one input (“active input”) using its time stamp as if the same time stamp is received from another input whose relation has fallen silent (“empty input”), if one or more predetermined conditions are met. One predetermined condition is that the empty input's operator has all its own inputs silent. And another predetermined condition is that a maximum time stamp that is currently present among all the inputs of the empty input's operator is equal to a time stamp that was last received from these same inputs. When both conditions are met, previously received data from the empty input is time stamped with the same time stamp as the most recently received data from the active input.

摘要翻译： 对数据流管理系统（DSMS）的新的连续查询可以使用其源不提供任何心跳的无声关系。 在执行任何给定的操作者期间，DSMS使用其时间戳来处理来自一个输入（“活动输入”）的数据，就好像从另一个输入中接收到相同时间标记的关系已经下沉（“空输入”），如果一个或 更符合规定的条件。 一个预定的条件是空输入的运算符具有所有自己的输入静音。 并且另一个预定条件是当前存在于空输入运算符的所有输入中的最大时间戳等于从这些相同输入最后接收的时间戳。 当满足这两个条件时，来自空输入的先前接收到的数据与来自活动输入的最近接收的数据具有相同的时间标记的时间戳。

公开(公告)号：US20050171945A1

公开(公告)日：2005-08-04

申请号：US11088340

申请日：2005-03-23

申请人： Carol Colrain ,  Namit Jain ,  Juan Loaiza

发明人： Carol Colrain ,  Namit Jain ,  Juan Loaiza

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

CPC分类号： G06F17/3048 ,  G06F17/30433 ,  Y10S707/99934 ,  Y10S707/99953

摘要： A system and method for enabling a second database instance to more quickly process a request to execute a database statement that has previously been executed by a first database instance is described. In one embodiment, the method involves sending the database statement from the first database instance to the second database instance, and generating by the second database instance one or more structures needed to prepare the statement for execution, such as a parse tree and an execution plan for the statement. If at some point in the future, the second database instance receives a request to execute the same statement, the above structures can be used for execution, thereby eliminating the need for one or more potentially time-consuming operations, such as generation of a parse tree or execution plan for the statement.

公开(公告)号：US08326822B2

公开(公告)日：2012-12-04

申请号：US13162882

申请日：2011-06-17

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

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

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

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.

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

公开(公告)号：US08296316B2

公开(公告)日：2012-10-23

申请号：US11874197

申请日：2007-10-17

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

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

IPC分类号： G06F7/00

CPC分类号： G06F17/30516

摘要： A new continuous query to a data stream management system (DSMS) may use several operators that are equivalent to operators currently being used by continuous queries that have been previously registered in the DSMS. To determine equivalence of operators, the DSMS checks at least the function and the data input to the operators. On finding equivalence, the DSMS modifies a global plan being executed, to use at least an existing subtree of operators during execution of the new continuous query, to generate a modified plan. The DSMS is also programmed to cause each relation source operator (which outputs a relation) to propagate a current state of the relation to each operator newly coupled to the relational operator. After propagation of current state to newly-coupled operators, each operator in the modified plan processes any new data and supplies the result to all operators coupled thereto, including newly-coupled operators and existing operators.

摘要翻译： 对数据流管理系统（DSMS）的新的连续查询可以使用几个等效于先前在DSMS中注册的连续查询使用的运算符的运算符。 为了确定运算符的等效性，DSMS至少检查运算符的功能和数据输入。 在发现等价性时，DSMS修改正在执行的全局计划，以便在执行新的连续查询期间至少使用现有的运算符子树来生成修改的计划。 DSMS还被编程为使得每个关系源操作符（其输出关系）将关系的当前状态传播到新耦合到关系运算符的每个运算符。 在将当前状态传播到新耦合的运营商之后，修改的计划中的每个运营商处理任何新的数据，并将结果提供给与其耦合的所有运营商，包括新耦合运营商和现有运营商。

公开(公告)号：US20120041934A1

公开(公告)日：2012-02-16

申请号：US13244272

申请日：2011-09-23

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

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

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

公开(公告)号：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被编程为使得输出关系的操作者将关系的当前状态传播到使用该关系的每个新耦合的运算符。 当前状态仅传播到已经新耦合的操作符，并且因此以前尚未接收到任何状态信息。 在将当前状态传播到新耦合的运营商之后，将与关联关系的任何新数据进行处理的结果提供给所有与之耦合的运营商，包括新耦合运营商和现有运营商。