公开(公告)号：US20080072221A1

公开(公告)日：2008-03-20

申请号：US11470137

申请日：2006-09-05

申请人： Gueorgui B. Chkodrov ,  Roger S. Barga

发明人： Gueorgui B. Chkodrov ,  Roger S. Barga

IPC分类号： G06F9/455

CPC分类号： G06F9/542 ,  G06F1/12 ,  G06F9/52 ,  G06F2209/544

摘要： A distributed event processing system that can organize (e.g., order) input streams regardless of actual time of receipt is provided. This order may simply be arrival order or given explicitly on a specific event attribute, such as a timestamp or sequence number. Traditional standing event queries, such as a temporal correlation of events across multiple streams, often block if an input stream is slow or may produce an incorrect answer if events fail to arrive within the fixed time interval. In response to this situation, the subject innovation employs punctuation and heartbeats in connection with a robust and scalable event processing system. The innovation discloses mechanisms by which heartbeats and timestamps can be regularly generated by low-level nodes (e.g., sources) and propagated through the network, to unblock standing event pattern queries and align events from multiple distributed streams.

摘要翻译： 提供了可以组织（例如，排序）输入流而不管实际接收时间的分布式事件处理系统。 该订单可以简单地是到达订单或者明确地给出特定事件属性，例如时间戳或序列号。 传统的常规事件查询，例如跨多个流的事件的时间相关性，如果输入流较慢或者如果事件在固定时间间隔内未能到达，则可能会产生不正确的答案。 针对这种情况，本发明采用标准化和心跳结合鲁棒且可扩展的事件处理系统。 该创新公开了通过这些机制，心跳和时间戳可以由低级节点（例如，源）定期生成并通过网络传播，以解除阻塞常规事件模式查询并对齐来自多个分布式流的事件。

公开(公告)号：US08296331B2

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

申请号：US12694062

申请日：2010-01-26

申请人： Gueorgui B. Chkodrov ,  Paul F. Ringseth ,  Tihomir T. Tarnavski ,  Andy Shen ,  Roger Shane Barga ,  Jonathan Goldstein

发明人： Gueorgui B. Chkodrov ,  Paul F. Ringseth ,  Tihomir T. Tarnavski ,  Andy Shen ,  Roger Shane Barga ,  Jonathan Goldstein

IPC分类号： G06F17/30

CPC分类号： G06F17/30516 ,  G06F17/30463 ,  Y10S707/99934

摘要： Creating and executing a distributed stream processing operator graph based on a query. The operator graph includes movable stream algebra operators for processing events received from high volume data streams. The operators are partially compiled and distributed to computing devices for completion of the compilation and subsequent execution. During execution, the operators maintain minimal state information associated with received events via an expiration time assigned to each of the event instances. Additional events are generated and aggregated by the operators for communication to a service responsible for the query.

摘要翻译： 基于查询创建和执行分布式流处理运算符图。 运算符图包括用于处理从高容量数据流接收的事件的可移动流代数运算符。 操作员被部分编译并分发到计算设备，以完成编译和后续执行。 在执行期间，运营商通过分配给每个事件实例的到期时间来保持与接收到的事件相关联的最小状态信息。 附加事件由运营商生成和聚合，用于与负责查询的服务进行通信。

公开(公告)号：US07774359B2

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

申请号：US11114444

申请日：2005-04-26

申请人： Gueorgui B. Chkodrov ,  Ahmed M. S. A. W. Moustafa ,  David S. Taniguchi ,  John D. Ballard ,  Richard Z. Jason

发明人： Gueorgui B. Chkodrov ,  Ahmed M. S. A. W. Moustafa ,  David S. Taniguchi ,  John D. Ballard ,  Richard Z. Jason

IPC分类号： G06F7/00

CPC分类号： G06Q10/087 ,  Y10S707/944

摘要： System and method for notifying a user of an occurrence of a defined condition in a process. The process includes a plurality of event records associated with the process; each of the plurality of event records includes a plurality of data fields having data relating to the process. A subset of the plurality of event records is defined where the subset relates to the defined condition. The data in the defined subset is updated at a predetermined time interval. The user is notified when the updated data of the defined subset indicates that the defined condition has occurred. The subset may alternatively be defined as a function of a current time, a last run time and the defined condition.

摘要翻译： 在过程中通知用户发生定义条件的系统和方法。 该过程包括与该过程相关联的多个事件记录; 多个事件记录中的每一个包括具有与该过程相关的数据的多个数据字段。 定义多个事件记录的子集，其中子集与定义的条件相关。 定义的子集中的数据以预定的时间间隔被更新。 当定义的子集的更新数据指示已经发生定义的条件时，通知用户。 可以将子集定义为当前时间，最后一个运行时间和所定义的条件的函数。

公开(公告)号：US08640083B2

公开(公告)日：2014-01-28

申请号：US13081242

申请日：2011-04-06

申请人： Vijay Mital ,  Maria Belousova ,  Gueorgui B. Chkodrov ,  Chandrika G. Shankarnarayan ,  Gregory Robert Prickril

发明人： Vijay Mital ,  Maria Belousova ,  Gueorgui B. Chkodrov ,  Chandrika G. Shankarnarayan ,  Gregory Robert Prickril

IPC分类号： G06F9/44

CPC分类号： G06Q10/10

摘要： Validating executable data for interactions among a plurality of process artifacts at design time. A data context is created to include the plurality of process artifacts. The data context carries interaction rules among the plurality of process artifacts. The executable data from a data source is associated with the plurality of process artifacts in the created data context. A subset of the interaction rules is selected corresponding to at least one of the plurality of process artifacts. The associated executable data is validated when the associated executable data is in accordance with the selected subset of the interaction rules.

摘要翻译： 验证在设计时在多个工艺工件之间的交互的可执行数据。 创建数据上下文以包括多个处理工件。 数据上下文在多个处理工件之间传送交互规则。 来自数据源的可执行数据与所创建的数据上下文中的多个处理工件相关联。 选择对应于多个处理工件中的至少一个的交互规则的子集。 当相关联的可执行数据与交互规则的选定子集相符时，关联的可执行数据被验证。

公开(公告)号：US20130014094A1

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

申请号：US13614184

申请日：2012-09-13

申请人： Gueorgui B. Chkodrov ,  Paul F. Ringseth ,  Tihomir T. Tarnavski ,  Andy Shen ,  Roger Shane Barga ,  Jonathan Goldstein

发明人： Gueorgui B. Chkodrov ,  Paul F. Ringseth ,  Tihomir T. Tarnavski ,  Andy Shen ,  Roger Shane Barga ,  Jonathan Goldstein

IPC分类号： G06F9/45

CPC分类号： G06F17/30516 ,  G06F17/30463 ,  Y10S707/99934

摘要： Creating and executing a distributed stream processing operator graph based on a query. The operator graph includes movable stream algebra operators for processing events received from high volume data streams. The operators are partially compiled and distributed to computing devices for completion of the compilation and subsequent execution. During execution, the operators maintain minimal state information associated with received events via an expiration time assigned to each of the event instances. Additional events are generated and aggregated by the operators for communication to a service responsible for the query.

公开(公告)号：US07941524B2

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

申请号：US11495271

申请日：2006-07-27

申请人： Gueorgui B. Chkodrov ,  Richard Z. Jason

发明人： Gueorgui B. Chkodrov ,  Richard Z. Jason

IPC分类号： G06F15/173

CPC分类号： G06F17/30368 ,  Y10S707/99938

摘要： Event data associated with state data corresponding to an instance of a process is collected by an interceptor associated with a server that performs an operation to modify the state data. The server performs a single transaction with the database to store both the modified state data and the associated event data, the transaction either succeeding or failing, whereby if the transaction succeeds, then both the state data and the event data are stored at the database, and if the transaction fails, then both the state data and the event data are not stored at the database. The event data stored at the database is then transmitted to a tracking service for conversion into a query-able format.

摘要翻译： 与对应于进程的实例的状态数据相关联的事件数据由与执行修改状态数据的操作的服务器相关联的拦截器收集。 服务器与数据库执行单一事务以存储修改的状态数据和相关联的事件数据，事务成功或失败，从而如果事务成功，则状态数据和事件数据都存储在数据库中， 并且如果事务失败，则状态数据和事件数据都不存储在数据库中。 然后将存储在数据库中的事件数据发送到跟踪服务以转换为可查询格式。

公开(公告)号：US06915509B1

公开(公告)日：2005-07-05

申请号：US09606973

申请日：2000-06-28

申请人： Gueorgui B. Chkodrov ,  Narinder Kaur

发明人： Gueorgui B. Chkodrov ,  Narinder Kaur

IPC分类号： G06F9/44 ,  G06F15/16

CPC分类号： G06F11/362

摘要： In a method and system for debugging a program, a debugging module is loaded into a normal thread of execution of the program. A user may then send commands to the debugger module from a command console module operating in a safe separate process. The debugger module receives the commands and converts them into function calls to objects that are accessible by the program. This allows the user to interact manually with the objects and achieve substantially the same responses from the objects as the program itself would have obtained during its normal execution. Thus the user can effectively debug the program without having to know the internal structure of any of its constituent objects.

摘要翻译： 在用于调试程序的方法和系统中，将调试模块加载到程序的正常执行线程中。 然后，用户可以从在安全的分离过程中操作的命令控制台模块向调试器模块发送命令。 调试器模块接收命令并将其转换为对程序可访问的对象的函数调用。 这允许用户与对象手动交互，并且从程序本身在其正常执行期间获得的对象获得与目标基本相同的响应。 因此，用户可以有效地调试程序而不必知道其任何组成对象的内部结构。

公开(公告)号：US20110185338A1

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

申请号：US13081242

申请日：2011-04-06

申请人： Vijay Mital ,  Maria Belousova ,  Gueorgui B. Chkodrov ,  Chandrika G. Shankarnarayan ,  Gregory Robert Prickril

发明人： Vijay Mital ,  Maria Belousova ,  Gueorgui B. Chkodrov ,  Chandrika G. Shankarnarayan ,  Gregory Robert Prickril

IPC分类号： G06F9/44

CPC分类号： G06Q10/10

摘要： Validating executable data for interactions among a plurality of process artifacts at design time. A data context is created to include the plurality of process artifacts. The data context carries interaction rules among the plurality of process artifacts. The executable data from a data source is associated with the plurality of process artifacts in the created data context. A subset of the interaction rules is selected corresponding to at least one of the plurality of process artifacts. The associated executable data is validated when the associated executable data is in accordance with the selected subset of the interaction rules.

摘要翻译： 验证在设计时在多个工艺工件之间的交互的可执行数据。 创建数据上下文以包括多个处理工件。 数据上下文在多个处理工件之间传送交互规则。 来自数据源的可执行数据与所创建的数据上下文中的多个处理工件相关联。 选择对应于多个处理工件中的至少一个的交互规则的子集。 当相关联的可执行数据与交互规则的选定子集相符时，关联的可执行数据被验证。

公开(公告)号：US07107340B2

公开(公告)日：2006-09-12

申请号：US10160844

申请日：2002-05-31

申请人： Gueorgui B. Chkodrov ,  Richard Z. Jason

发明人： Gueorgui B. Chkodrov ,  Richard Z. Jason

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

CPC分类号： G06F17/30368 ,  Y10S707/99938

摘要： Event data associated with state data corresponding to an instance of a process is collected by an interceptor associated with a server that performs an operation to modify the state data. The server performs a single transaction with the database to store both the modified state data and the associated event data, the transaction either succeeding or failing, whereby if the transaction succeeds, then both the state data and the event data are stored at the database, and if the transaction fails, then both the state data and the event data are not stored at the database. The event data stored at the database is then transmitted to a tracking service for conversion into a query-able format.

公开(公告)号：US08775482B2

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

申请号：US13614184

申请日：2012-09-13

申请人： Gueorgui B. Chkodrov ,  Paul F. Ringseth ,  Tihomir T. Tarnavski ,  Andy Shen ,  Roger Shane Barga ,  Jonathan Goldstein

发明人： Gueorgui B. Chkodrov ,  Paul F. Ringseth ,  Tihomir T. Tarnavski ,  Andy Shen ,  Roger Shane Barga ,  Jonathan Goldstein

IPC分类号： G06F17/30

CPC分类号： G06F17/30516 ,  G06F17/30463 ,  Y10S707/99934

摘要： Creating and executing a distributed stream processing operator graph based on a query. The operator graph includes movable stream algebra operators for processing events received from high volume data streams. The operators are partially compiled and distributed to computing devices for completion of the compilation and subsequent execution. During execution, the operators maintain minimal state information associated with received events via an expiration time assigned to each of the event instances. Additional events are generated and aggregated by the operators for communication to a service responsible for the query.

摘要翻译： 基于查询创建和执行分布式流处理运算符图。 运算符图包括用于处理从高容量数据流接收的事件的可移动流代数运算符。 操作员被部分编译并分发到计算设备，以完成编译和后续执行。 在执行期间，运营商通过分配给每个事件实例的到期时间来保持与接收到的事件相关联的最小状态信息。 附加事件由运营商生成和聚合，用于与负责查询的服务进行通信。