公开(公告)号：US07418462B2

公开(公告)日：2008-08-26

申请号：US10720622

申请日：2003-11-24

申请人： David B. Lomet ,  Roger S. Barga

发明人： David B. Lomet ,  Roger S. Barga

IPC分类号： G06F17/30 ,  G06F15/16 ,  G06F11/00

CPC分类号： G06F11/1471 ,  Y10S707/99938 ,  Y10S707/99953

摘要： A system, method and computer-readable medium for optimizing recovery logging is provided. A calling component stably logs a message from a called component only when sending a second message or sending a second message after a log force that writes the return message from the first message to the stable log. The called component stably logs its return message before the return message is sent.

摘要翻译： 提供了一种用于优化恢复记录的系统，方法和计算机可读介质。 一个呼叫组件只有在发送第二个消息或者在将返回消息从第一个消息写入到稳定日志的日志强制之后发送第二个消息时，才稳定地记录来自被叫组件的消息。 被叫组件在发送返回消息之前稳定地记录其返回消息。

公开(公告)号：US07093162B2

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

申请号：US10879324

申请日：2004-06-29

申请人： Roger S. Barga ,  David B. Lomet

发明人： Roger S. Barga ,  David B. Lomet

IPC分类号： G06F11/00

CPC分类号： G06F11/1482 ,  G06F11/1438 ,  G06F11/1471

摘要： Persistent components are provided across both process and server failures, without the application programmer needing take actions for component recoverability. Application interactions with a stateful component are transparently intercepted and stably logged to persistent storage. A “virtual” component isolates an application from component failures, permitting the mapping of a component to an arbitrary “physical” component. Component failures are detected and masked from the application. A virtual component is re-mapped to a new physical component, and the operations required to recreate a component and reinstall state up to the point of the last logged interaction is replayed from the log automatically.

摘要翻译： 在进程和服务器故障之间提供持久组件，而不需要应用程序员采取措施来实现组件可恢复性。 与状态组件的应用程序交互被透明地拦截并稳定地记录到持久存储器中。 “虚拟”组件将应用程序与组件故障隔离，允许将组件映射到任意“物理”组件。 从应用程序检测并屏蔽组件故障。 一个虚拟组件被重新映射到一个新的物理组件，重新创建组件并重新安装状态直到上次记录的交互操作所需的操作将从日志自动重播。

公开(公告)号：US07461292B2

公开(公告)日：2008-12-02

申请号：US10977709

申请日：2004-10-29

申请人： Roger S. Barga ,  David B. Lomet

发明人： Roger S. Barga ,  David B. Lomet

IPC分类号： G06F11/00

CPC分类号： G06F11/1482 ,  G06F11/1438 ,  G06F11/1471

摘要： Persistent components are provided across both process and server failures, without the application programmer needing take actions for component recoverability. Application interactions with a stateful component are transparently intercepted and stably logged to persistent storage. A “virtual” component isolates an application from component failures, permitting the mapping of a component to an arbitrary “physical” component. Component failures are detected and masked from the application. A virtual component is re-mapped to a new physical component, and the operations required to recreate a component and reinstall state up to the point of the last logged interaction is replayed from the log automatically.

摘要翻译： 在进程和服务器故障之间提供持久组件，而不需要应用程序员采取措施来实现组件可恢复性。 与状态组件的应用程序交互被透明地拦截并稳定地记录到持久存储器中。 “虚拟”组件将应用程序与组件故障隔离，允许将组件映射到任意“物理”组件。 从应用程序检测并屏蔽组件故障。 一个虚拟组件被重新映射到一个新的物理组件，重新创建组件并重新安装状态直到上次记录的交互操作所需的操作将从日志自动重播。

公开(公告)号：US06820218B1

公开(公告)日：2004-11-16

申请号：US09946092

申请日：2001-09-04

申请人： Roger S. Barga ,  David B. Lomet

发明人： Roger S. Barga ,  David B. Lomet

IPC分类号： G06F1100

CPC分类号： G06F11/1482 ,  G06F11/1438 ,  G06F11/1471

摘要： Persistent components are provided across both process and server failures, without the application programmer needing take actions for component recoverability. Application interactions with a stateful component are transparently intercepted and stably logged to persistent storage. A “virtual” component isolates an application from component failures, permitting the mapping of a component to an arbitrary “physical” component. Component failures are detected and masked from the application. A virtual component is re-mapped to a new physical component, and the operations required to recreate a component and reinstall state up to the point of the last logged interaction is replayed from the log automatically.

摘要翻译： 在进程和服务器故障之间提供持久组件，而不需要应用程序员采取措施来实现组件可恢复性。 与状态组件的应用程序交互被透明地拦截并稳定地记录到持久存储器中。 “虚拟”组件将应用程序与组件故障隔离，允许将组件映射到任意“物理”组件。 从应用程序检测并屏蔽组件故障。 一个虚拟组件被重新映射到一个新的物理组件，重新创建组件并重新安装状态直到上次记录的交互操作所需的操作将从日志自动重播。

公开(公告)号：US08386440B2

公开(公告)日：2013-02-26

申请号：US11125806

申请日：2005-05-10

申请人： David B. Lomet ,  Roger S. Barga

发明人： David B. Lomet ,  Roger S. Barga

IPC分类号： G06F7/00 ,  G06F13/00 ,  G06F11/00

CPC分类号： G06F11/1474

摘要： The subject invention pertains to data store corruption recovery. More specifically, the invention concerns systems and methods for identifying corrupt data in a manner that prevents de-committing or removal of valid or consistent transactions from a database. This can be accomplished at least in part by logging the identities of data items that a transaction reads. Furthermore, the subject invention provides for employment of a multi-version (or transaction-time) database to reduce significantly reduce any down time or database unavailability caused by a corrupt transaction and associated corrupt data items. Accordingly, no backups need to be installed and only updates by the original corrupt transaction and transactions that read corrupt data need to be de-committed or removed.

摘要翻译： 本发明涉及数据存储损坏恢复。 更具体地，本发明涉及用于以防止从数据库中取消或删除有效或一致的事务的方式来识别腐败数据的系统和方法。 这可以至少部分地通过记录事务读取的数据项的身份来实现。 此外，本发明提供使用多版本（或交易时间）数据库以减少显着地减少由破坏的事务和相关的损坏的数据项导致的任何停机时间或数据库不可用性。 因此，不需要安装备份，只有原始损坏的事务才能进行更新，而需要取消删除已损坏数据的事务。

公开(公告)号：US20110061008A1

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

申请号：US12098805

申请日：2008-04-07

申请人： Anoop Gupta ,  Mary P. Czerwinski ,  Pavel Curtis ,  Richard J. McAniff ,  Roger S. Barga ,  Rebecca Norlander ,  Raymond E. Ozzie

发明人： Anoop Gupta ,  Mary P. Czerwinski ,  Pavel Curtis ,  Richard J. McAniff ,  Roger S. Barga ,  Rebecca Norlander ,  Raymond E. Ozzie

IPC分类号： G06F3/048

CPC分类号： G06F16/285 ,  G06Q10/107

摘要： A single device that receives communications, resources, data, and/or other information intended for a user having multiple contact addresses is provided. The single device can receive various information intended for multiple telephone numbers, email aliases, screen names, aliases, other means of contact, or combinations thereof. The device can selectively forward the information to the user based on a current user role, user preferences, contact information, or based on other criteria. If information is to be forwarded to the user at substantially the same time as receipt, automatic means of notifying the user of the role for which the communication is intended are provided.

摘要翻译： 提供了接收用于具有多个联系人地址的用户的通信，资源，数据和/或其他信息的单个设备。 单个设备可以接收针对多个电话号码，电子邮件别名，屏幕名称，别名，其他联系方式或其组合的各种信息。 该设备可以基于当前用户角色，用户偏好，联系人信息或基于其他标准来选择性地将信息转发给用户。 如果在与接收的基本相同的时间将信息转发给用户，则提供通知用户该通信所针对的角色的自动装置。

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

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

公开(公告)号：US08635331B2

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

申请号：US12535698

申请日：2009-08-05

申请人： Nelson Sampaio Araujo, Jr. ,  Roger S. Barga ,  Jared J. Jackson ,  Di Guo

发明人： Nelson Sampaio Araujo, Jr. ,  Roger S. Barga ,  Jared J. Jackson ,  Di Guo

IPC分类号： G06F15/173

CPC分类号： G06F9/54 ,  G06F17/30132 ,  H04L63/102

摘要： Aspects of the subject matter described herein relate to workflows. In aspects, an activity of a workflow may request data and provide a logical handle. In response, distributed workflow components use the logical handle to determine whether the requested data is available locally or remotely. If the data is available remotely, the components may obtain the data for the requesting entity. In the process of obtaining the data, the data may be serialized and deserialized. After the data is available locally, it is provided to the requesting entity.

摘要翻译： 本文描述的主题的方面涉及工作流程。 在方面中，工作流的活动可以请求数据并提供逻辑句柄。 作为响应，分布式工作流组件使用逻辑句柄来确定所请求的数据是否在本地或远程可用。 如果数据远程可用，组件可以获取请求实体的数据。 在获取数据的过程中，数据可以被序列化和反序列化。 数据在本地可用之后，它被提供给请求实体。

公开(公告)号：US08060614B2

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

申请号：US12141914

申请日：2008-06-19

申请人： Jonathan D. Goldstein ,  Roger S. Barga ,  Mirek Riedewald ,  Mingsheng Hong

发明人： Jonathan D. Goldstein ,  Roger S. Barga ,  Mirek Riedewald ,  Mingsheng Hong

IPC分类号： G06F15/16

CPC分类号： G06F9/5083

摘要： A streaming operator assignment system and method for determining a streaming operator assignment that minimizes overload in a data processing system. Embodiments of the streaming operator assignment system include an optimization goals definition module, which defines optimization goals in terms of fundamental quantities that system administrators and application writers want to control, such as minimizing the worst case latency over all periods of time, or minimizing how much the system is backlogged with work. Embodiments of the streaming operator assignment system also include an optimization goals solution module that optimizes and solves a selected optimization goal. A specialized optimization technique is used to find the best operator (or load) assignment using the optimization goals to measure of the value of the assignment. This technique minimizes an optimization goal by iterating over all possible operators assignments over all possible nodes to find the operator assignment that minimizes the desired optimization goal.

摘要翻译： 一种用于确定使数据处理系统中的过载最小化的流操作员分配的流操作员分配系统和方法。 流操作者分配系统的实施例包括优化目标定义模块，其定义系统管理员和应用程序编写者想要控制的基本量的优化目标，例如最小化所有时间段内的最坏情况延迟，或最小化多少 系统用工作积压。 流式操作员分配系统的实施例还包括优化和解决所选优化目标的优化目标解决方案模块。 使用专门的优化技术来使用优化目标来找到最佳的运算符（或加载）分配，以度量分配值。 该技术通过遍历所有可能节点上的所有可能的运算符分配来最小化优化目标，以找到最小化期望的优化目标的运算符分配。

公开(公告)号：US08892658B2

公开(公告)日：2014-11-18

申请号：US12098697

申请日：2008-04-07

申请人： Anoop Gupta ,  Mary P. Czerwinski ,  Roger S. Barga ,  Pavel Curtis ,  Paul J. Hough ,  Richard J. McAniff ,  Raymond E. Ozzie

发明人： Anoop Gupta ,  Mary P. Czerwinski ,  Roger S. Barga ,  Pavel Curtis ,  Paul J. Hough ,  Richard J. McAniff ,  Raymond E. Ozzie

IPC分类号： G06F15/16 ,  G06Q10/10 ,  H04M3/436 ,  H04L12/58 ,  H04L29/08 ,  H04M3/42

CPC分类号： H04M3/436 ,  G06Q10/107 ,  H04L51/14 ,  H04L51/24 ,  H04L67/24 ,  H04M3/42229

摘要： A single device that receives communications intended for a user having multiple contact addresses associated with different user roles is provided. The single device can receive communications intended for multiple telephone numbers, email aliases, screen names, aliases, other means of contact, or combinations thereof. Since a user engaged in a particular role might not desire to be interrupted with communications intended for a different role, the communications for the other roles can be maintained until the user is actively engaged in the role for which the communication was intended. In situations where there is an important communication sent to a non-active role, selective convergence between roles is initiated and the important communication is presented to the user.

摘要翻译： 提供了接收针对具有与不同用户角色相关联的多个联系人地址的用户的通信的单个设备。 单个设备可以接收旨在用于多个电话号码，电子邮件别名，屏幕名称，别名，其他联系方式或其组合的通信。 由于从事特定角色的用户可能不希望被打断用于不同角色的通信，所以可以维护用于其他角色的通信，直到用户积极地参与到通信打算的角色为止。 在将重要通信发送到非主动角色的情况下，启动角色之间的选择性融合，并向用户呈现重要的通信。