公开(公告)号：US08234329B2

公开(公告)日：2012-07-31

申请号：US12623595

申请日：2009-11-23

申请人： Sreekanth R. Iyer ,  Gowdhaman Jayaseelan ,  Jojo Joseph

发明人： Sreekanth R. Iyer ,  Gowdhaman Jayaseelan ,  Jojo Joseph

IPC分类号： G06F15/16

CPC分类号： G06F9/542

摘要： A method, a system and a computer program for parallel event processing in an event processing network (EPN) are disclosed. The EPN has at least one event processing agent (EPA). The method includes assigning an execution mode for the at least one EPA, the execution mode including a concurrent mode and a sequential mode. The execution mode for the at least one EPA is stored in the EPN metadata. The method also includes loading and initializing the EPN. The method further includes routing the event in the EPN and, when an EPA is encountered, depending on the execution mode of the encountered EPA, further processing of the event. Also disclosed are a system and a computer program for parallel event processing in an event processing network (EPN).

摘要翻译： 公开了一种用于事件处理网络（EPN）中的并行事件处理的方法，系统和计算机程序。 EPN至少有一个事件处理代理（EPA）。 所述方法包括为所述至少一个EPA分配执行模式，所述执行模式包括并发模式和顺序模式。 至少一个EPA的执行模式被存储在EPN元数据中。 该方法还包括加载和初始化EPN。 该方法还包括在EPN中路由该事件，并且当遇到EPA时，取决于所遇到的EPA的执行模式，进一步处理该事件。 还公开了一种用于事件处理网络（EPN）中的并行事件处理的系统和计算机程序。

公开(公告)号：US09977702B2

公开(公告)日：2018-05-22

申请号：US12623673

申请日：2009-11-23

申请人： Sreekanth R. Iyer ,  Gowdhaman Jayaseelan ,  Jojo Joseph

发明人： Sreekanth R. Iyer ,  Gowdhaman Jayaseelan ,  Jojo Joseph

IPC分类号： G06F9/54

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

摘要： A hybrid event processing network (EPN) having at least one event processing agent (EPA) consists of a first set of EPAs defined declaratively and a second set of EPAs defined dynamically at runtime via an interface. Deploying the hybrid EPN includes loading the hybrid EPN, constructing an EPN structure, and creating indexes of nodes of the EPN structure. Deploying the hybrid EPN further includes representing an event in a hybrid EPN, and, in response to the event occurrence at an event source, receiving a notification from the hybrid EPN based on the event, and publishing the notification in an event channel. Embodiments of the invention includes propagating the event received within the hybrid EPN, determining a subsequent EPA associated with the event within the hybrid EPN, and propagating the event to the subsequent EPA in the hybrid EPN until the last element of the hybrid EPN is reached.

公开(公告)号：US08694576B2

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

申请号：US13428238

申请日：2012-03-23

申请人： Sreekanth R. Iyer ,  Gowdhaman Jayaseelan ,  Jojo Joseph

发明人： Sreekanth R. Iyer ,  Gowdhaman Jayaseelan ,  Jojo Joseph

IPC分类号： G06F15/16

CPC分类号： G06F9/542

摘要： A method, a system and a computer program for parallel event processing in an event processing network (EPN) are disclosed. The EPN has at least one event processing agent (EPA). The method includes assigning an execution mode for the at least one EPA, the execution mode including a concurrent mode and a sequential mode. The execution mode for the at least one EPA is stored in the EPN metadata. The method also includes loading and initializing the EPN. The method further includes routing the event in the EPN and, when an EPA is encountered, depending on the execution mode of the encountered EPA, further processing of the event. Also disclosed are a system and a computer program for parallel event processing in an event processing network (EPN).

摘要翻译： 公开了一种用于事件处理网络（EPN）中的并行事件处理的方法，系统和计算机程序。 EPN至少有一个事件处理代理（EPA）。 所述方法包括为所述至少一个EPA分配执行模式，所述执行模式包括并发模式和顺序模式。 至少一个EPA的执行模式被存储在EPN元数据中。 该方法还包括加载和初始化EPN。 该方法还包括在EPN中路由该事件，并且当遇到EPA时，取决于所遇到的EPA的执行模式，进一步处理该事件。 还公开了一种用于事件处理网络（EPN）中的并行事件处理的系统和计算机程序。

公开(公告)号：US20110126201A1

公开(公告)日：2011-05-26

申请号：US12623673

申请日：2009-11-23

申请人： Sreekanth R. Iyer ,  Gowdhaman Jayaseelan ,  Jojo Joseph

发明人： Sreekanth R. Iyer ,  Gowdhaman Jayaseelan ,  Jojo Joseph

IPC分类号： G06F9/46

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

摘要： A hybrid event processing network (EPN) having at least one event processing agent (EPA) consists of a first set of EPAs defined declaratively and a second set of EPAs defined dynamically at runtime via an interface. Deploying the hybrid EPN includes loading the hybrid EPN, constructing an EPN structure, and creating indexes of nodes of the EPN structure. Deploying the hybrid EPN further includes representing an event in a hybrid EPN, and, in response to the event occurrence at an event source, receiving a notification from the hybrid EPN based on the event, and publishing the notification in an event channel. Embodiments of the invention includes propagating the event received within the hybrid EPN, determining a subsequent EPA associated with the event within the hybrid EPN, and propagating the event to the subsequent EPA in the hybrid EPN until the last element of the hybrid EPN is reached.

摘要翻译： 具有至少一个事件处理代理（EPA）的混合事件处理网络（EPN）包括由声明定义的第一组EPA和经由接口在运行时动态定义的第二组EPA。 部署混合EPN包括加载混合EPN，构建EPN结构，并创建EPN结构节点的索引。 混合EPN还包括表示混合EPN中的事件，并且响应于事件源处的事件发生，基于事件从混合EPN接收通知，并且在事件通道中发布通知。 本发明的实施例包括传播在混合EPN内接收的事件，确定与混合EPN内的事件相关联的随后的EPA，并将事件传播到混合EPN中的后续EPA，直到达到混合EPN的最后一个元素。

公开(公告)号：US20110125825A1

公开(公告)日：2011-05-26

申请号：US12623595

申请日：2009-11-23

申请人： Sreekanth R. Iyer ,  Gowdhaman Jayaseelan ,  Jojo Joseph

发明人： Sreekanth R. Iyer ,  Gowdhaman Jayaseelan ,  Jojo Joseph

IPC分类号： G06F15/16 ,  G06F15/173 ,  G06F9/46

CPC分类号： G06F9/542

摘要： A method, a system and a computer program for parallel event processing in an event processing network (EPN) are disclosed. The EPN has at least one event processing agent (EPA). The method includes assigning an execution mode for the at least one EPA, the execution mode including a concurrent mode and a sequential mode. The execution mode for the at least one EPA is stored in the EPN metadata. The method also includes loading and initializing the EPN. The method further includes routing the event in the EPN and, when an EPA is encountered, depending on the execution mode of the encountered EPA, further processing of the event. Also disclosed are a system and a computer program for parallel event processing in an event processing network (EPN).

摘要翻译： 公开了一种用于事件处理网络（EPN）中的并行事件处理的方法，系统和计算机程序。 EPN至少有一个事件处理代理（EPA）。 所述方法包括为所述至少一个EPA分配执行模式，所述执行模式包括并发模式和顺序模式。 至少一个EPA的执行模式被存储在EPN元数据中。 该方法还包括加载和初始化EPN。 该方法还包括在EPN中路由该事件，并且当遇到EPA时，取决于所遇到的EPA的执行模式，进一步处理该事件。 还公开了一种用于事件处理网络（EPN）中的并行事件处理的系统和计算机程序。

公开(公告)号：US20120191763A1

公开(公告)日：2012-07-26

申请号：US13434695

申请日：2012-03-29

申请人： Jojo Joseph

发明人： Jojo Joseph

IPC分类号： G06F17/30

CPC分类号： G06F17/3048

摘要： A batch of data records generated by at least one application for persistent storage is cached by a cache management device. At least one of the batch of data records includes at least one foreign key reference that each references one non-existent data record. It is determined that one of a group of batch database storage events has occurred. In response to one of the group of batch database storage events, it is iteratively determined which of the at least one of the batch of data records do not include the at least one foreign key reference that each references the one non-existent data record. Each of the cached batch of data records that do not include the at least one foreign key reference that each references the one non-existent data record is persisted to a database by a batch storage operation.

摘要翻译： 由至少一个用于持久存储的应用程序生成的一批数据记录被缓存管理设备缓存。 批次数据记录中的至少一个包括至少一个引用一个不存在的数据记录的外键引用。 确定发生了一组批量数据库存储事件之一。 响应于一批批量数据库存储事件之一，迭代地确定该批数据记录中的至少一个数据记录中的哪一个不包括每个引用一个不存在的数据记录的至少一个外键引用。 每个不包含至少一个引用一个不存在的数据记录的外键引用的缓存的数据记录批次通过批量存储操作保存到数据库。

公开(公告)号：US20120072470A1

公开(公告)日：2012-03-22

申请号：US12888030

申请日：2010-09-22

申请人： Jojo Joseph

发明人： Jojo Joseph

IPC分类号： G06F7/00 ,  G06F12/08 ,  G06F12/00

CPC分类号： G06F17/3048

摘要： A batch of data records generated by at least one application for persistent storage is cached by a cache management device. At least one of the batch of data records includes at least one foreign key reference that each references one non-existent data record. It is determined that one of a group of batch database storage events has occurred. In response to one of the group of batch database storage events, it is iteratively determined which of the at least one of the batch of data records do not include the at least one foreign key reference that each references the one non-existent data record. Each of the cached batch of data records that do not include the at least one foreign key reference that each references the one non-existent data record is persisted to a database by a batch storage operation.

公开(公告)号：US08533240B2

公开(公告)日：2013-09-10

申请号：US12888030

申请日：2010-09-22

申请人： Jojo Joseph

发明人： Jojo Joseph

IPC分类号： G06F17/30

CPC分类号： G06F17/3048

摘要： A batch of data records generated by at least one application for persistent storage is cached by a cache management device. At least one of the batch of data records includes at least one foreign key reference that each references one non-existent data record. It is determined that one of a group of batch database storage events has occurred. In response to one of the group of batch database storage events, it is iteratively determined which of the at least one of the batch of data records do not include the at least one foreign key reference that each references the one non-existent data record. Each of the cached batch of data records that do not include the at least one foreign key reference that each references the one non-existent data record is persisted to a database by a batch storage operation.

摘要翻译： 由至少一个用于持久存储的应用程序生成的一批数据记录被缓存管理设备缓存。 批次数据记录中的至少一个包括至少一个引用一个不存在的数据记录的外键引用。 确定发生了一组批量数据库存储事件之一。 响应于一批批量数据库存储事件之一，迭代地确定该批数据记录中的至少一个数据记录中的哪一个不包括每个引用一个不存在的数据记录的至少一个外键引用。 每个不包含至少一个引用一个不存在的数据记录的外键引用的缓存的数据记录批次通过批量存储操作保存到数据库。

公开(公告)号：US08527557B2

公开(公告)日：2013-09-03

申请号：US13434695

申请日：2012-03-29

申请人： Jojo Joseph

发明人： Jojo Joseph

IPC分类号： G06F17/30

CPC分类号： G06F17/3048

摘要： A batch of data records generated by at least one application for persistent storage is cached by a cache management device. At least one of the batch of data records includes at least one foreign key reference that each references one non-existent data record. It is determined that one of a group of batch database storage events has occurred. In response to one of the group of batch database storage events, it is iteratively determined which of the at least one of the batch of data records do not include the at least one foreign key reference that each references the one non-existent data record. Each of the cached batch of data records that do not include the at least one foreign key reference that each references the one non-existent data record is persisted to a database by a batch storage operation.

公开(公告)号：US07895190B2

公开(公告)日：2011-02-22

申请号：US12146058

申请日：2008-06-25

申请人： Jojo Joseph

发明人： Jojo Joseph

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

CPC分类号： G06F17/30911 ,  G06F17/30917

摘要： A method is disclosed for indexing and querying XML documents stored in a relational database. A user is allowed to choose columns of a database table for storing XML data of a known structure. The user has to input one or more XML paths for indexed data. Each path is stored in a static index table. In response to the input of the user defined paths, at least one dynamic index table is created for each static index table. The dynamic index table is updated upon data being entered into the database table. When a user's query is intercepted, any XML expression part of the query is processed and converted into one or more rows in the static index table. A new query is generated against the dynamic indexing tables, using the values obtained from the static index table, and executed. The user's query is then rewritten by transforming the XML path part of the user's query expression into a format understood by the database query engine. Finally, after the rewritten query is executed, the result is returned to the user, together with any non-XML part of the user's query, executed by the database query engine.

摘要翻译： 公开了一种用于索引和查询存储在关系数据库中的XML文档的方法。 允许用户选择用于存储已知结构的XML数据的数据库表的列。 用户必须为索引数据输入一个或多个XML路径。 每个路径都存储在静态索引表中。 响应于用户定义的路径的输入，为每个静态索引表创建至少一个动态索引表。 动态索引表在数据输入数据库表时更新。 当用户的查询被拦截时，查询的任何XML表达式部分将被处理并转换成静态索引表中的一行或多行。 使用从静态索引表获取的值并执行的动态索引表生成新的查询。 然后通过将用户查询表达式的XML路径部分转换为数据库查询引擎所理解的格式来重写用户的查询。 最后，执行重写查询后，结果将返回给用户，以及由数据库查询引擎执行的用户查询的任何非XML部分。