公开(公告)号：US08478743B2

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

申请号：US12977107

申请日：2010-12-23

申请人： Badrish Chandramouli ,  Jonathan David Goldstein ,  Peter Alfred Zabback ,  David Eugene Maier ,  Di Wang

发明人： Badrish Chandramouli ,  Jonathan David Goldstein ,  Peter Alfred Zabback ,  David Eugene Maier ,  Di Wang

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

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

摘要： Described herein are technologies pertaining to migrating state information of operators in a first continuous query plan to a second continuous query plan in an asynchronous manner, such that the first continuous query plan need not cease executing during the migrating of the state information. State information pertaining to stateful operators, such as join operators, is migrated from the first continuous query plan to the second continuous query plan by way of a transformation plan. State matching is utilized to generate the transformation plan.

摘要翻译： 这里描述的是涉及将第一连续查询计划中的运营商的状态信息以异步方式迁移到第二连续查询计划的技术，使得在迁移状态信息期间第一连续查询计划不需要停止执行。 通过转换方案，将有状态运算符（例如加入运算符）的状态信息从第一个连续查询计划迁移到第二个连续查询计划。 利用状态匹配来生成转换计划。

公开(公告)号：US20120297080A1

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

申请号：US13108005

申请日：2011-05-16

申请人： Colin Joseph Meek ,  Mohamed Hassan Ali ,  Galex Sunyul Yen ,  Ciprian Gerea ,  Balan Sethu Raman ,  Jonathan David Goldstein ,  Badrish Chandramouli ,  Tomer Verona ,  Torsten Walther Grabs

发明人： Colin Joseph Meek ,  Mohamed Hassan Ali ,  Galex Sunyul Yen ,  Ciprian Gerea ,  Balan Sethu Raman ,  Jonathan David Goldstein ,  Badrish Chandramouli ,  Tomer Verona ,  Torsten Walther Grabs

IPC分类号： G06F15/16

CPC分类号： G06F9/542

摘要： Aspects of the subject matter described herein relate to stream operators. In aspects, a stream event is received. Based on a timestamp associated with the stream event and the number of stream operators that have asked to be activated prior to or at the timestamp, zero or more stream objects are informed of one or more time events and torn down if no longer needed. In addition, a destination stream operator is instantiated, if needed, data (e.g., the timestamp and packet, if any) corresponding to the stream event is provided to a stream operator, output data, if any, is received from the stream operator, and the stream operator is torn down if it no longer needs state data between invocations.

摘要翻译： 本文描述的主题的方面涉及流操作员。 在方面，接收流事件。 基于与流事件相关联的时间戳和要求在时间戳之前或时间戳处被激活的流运算符的数量，零或多个流对象被通知一个或多个时间事件，并且如果不再需要则被拆除。 另外，如果需要，将目的地流运算符进行实例化，将与流事件相对应的数据（例如，时间戳和分组，如果有的话）提供给流运算符，则从流运算符接收输出数据（如果有的话） 如果流操作员不再需要调用之间的状态数据，则该流操作符将被拆除。

公开(公告)号：US08683074B2

公开(公告)日：2014-03-25

申请号：US13108005

申请日：2011-05-16

申请人： Colin Joseph Meek ,  Mohamed Hassan Ali ,  Galex Sunyul Yen ,  Ciprian Gerea ,  Balan Sethu Raman ,  Jonathan David Goldstein ,  Badrish Chandramouli ,  Tomer Verona ,  Torsten Walther Grabs

发明人： Colin Joseph Meek ,  Mohamed Hassan Ali ,  Galex Sunyul Yen ,  Ciprian Gerea ,  Balan Sethu Raman ,  Jonathan David Goldstein ,  Badrish Chandramouli ,  Tomer Verona ,  Torsten Walther Grabs

IPC分类号： G06F15/16

CPC分类号： G06F9/542

摘要： Aspects of the subject matter described herein relate to stream operators. In aspects, a stream event is received. Based on a timestamp associated with the stream event and the number of stream operators that have asked to be activated prior to or at the timestamp, zero or more stream objects are informed of one or more time events and torn down if no longer needed. In addition, a destination stream operator is instantiated, if needed, data (e.g., the timestamp and packet, if any) corresponding to the stream event is provided to a stream operator, output data, if any, is received from the stream operator, and the stream operator is torn down if it no longer needs state data between invocations.

摘要翻译： 本文描述的主题的方面涉及流操作员。 在方面，接收流事件。 基于与流事件相关联的时间戳和要求在时间戳之前或时间戳处被激活的流运算符的数量，零或多个流对象被通知一个或多个时间事件，并且如果不再需要则被拆除。 另外，如果需要，将目的地流运算符进行实例化，将与流事件相对应的数据（例如，时间戳和分组，如果有的话）提供给流运算符，则从流运算符接收输出数据（如果有的话） 如果流操作员不再需要调用之间的状态数据，则该流操作符将被拆除。

公开(公告)号：US20090319501A1

公开(公告)日：2009-12-24

申请号：US12144698

申请日：2008-06-24

申请人： Jonathan David Goldstein ,  Mingsheng Hong

发明人： Jonathan David Goldstein ,  Mingsheng Hong

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

CPC分类号： G06F16/24568 ,  G06F16/2452 ,  G06F16/258

摘要： A query translation system and method for processing a streaming language query on existing or stored data. The streaming language query is applied against a data stream log by first translating the streaming language query into a database management system query (such as a SQL query) and then applying the translated streaming language query against the data stream log. Embodiments of the query translation system and method include a bitemporal converter that converts a bitemporal data stream log into a canonical history table format. Once in this format, embodiments of the query translation system and method translate a streaming language query into a SQL query. A categorization of each of the streaming operators that make up the streaming language query is performed to determine which translation technique to use. In general, one of three general translation techniques is used based on these categorizations of the streaming operators.

摘要翻译： 用于处理对现有或存储的数据的流式语言查询的查询翻译系统和方法。 通过首先将流式语言查询翻译成数据库管理系统查询（例如SQL查询），然后针对数据流日志应用翻译的流式语言查询，对数据流日志应用流式语言查询。 查询翻译系统和方法的实施例包括将时间数据流日志转换为规范历史表格式的时间转换器。 一旦采用这种格式，查询翻译系统和方法的实施例将流式语言查询转换成SQL查询。 执行构成流式语言查询的每个流操作符的分类，以确定要使用的翻译技术。 一般来说，基于流操作员的这些分类使用三种一般翻译技术之一。

公开(公告)号：US09274842B2

公开(公告)日：2016-03-01

申请号：US12825336

申请日：2010-06-29

申请人： David A. Maltz ,  Jonathan David Goldstein ,  Albert Greenberg ,  Charles Loboz ,  Parveen K. Patel

发明人： David A. Maltz ,  Jonathan David Goldstein ,  Albert Greenberg ,  Charles Loboz ,  Parveen K. Patel

IPC分类号： G06F15/173 ,  G06F9/50 ,  G06F11/30 ,  G06F11/34 ,  H04L12/26

CPC分类号： H04L43/0876 ,  G06F9/5027 ,  G06F11/3006 ,  G06F11/3072 ,  G06F11/3093 ,  G06F11/3409 ,  G06F11/3495 ,  G06F17/30864 ,  G06F2201/88 ,  G06F2209/5013 ,  H04L43/0817

摘要： Described is a server monitoring technology that is scalable to large numbers of servers, e.g., in a datacenter. Agents on servers run queries to monitor data sources for that server, such as performance counters and other events. The agents monitor their resource usage and those of monitored events to stay within an administrator-specified resource budget (policy), e.g., by modifying the running queries and/or monitoring parameters. A controller receives results of the monitoring, analyzes the results, and takes action as needed with respect to server operation and monitoring. The controller may dynamically update an agent's queries, monitoring parameters and/or monitored data post-processing operations. The controller may issue alerts and reports, including alerts indicative of inter-server problems between two or more servers.

摘要翻译： 描述了可扩展到大量服务器的服务器监控技术，例如在数据中心中。 服务器上的代理运行查询以监视该服务器的数据源，例如性能计数器和其他事件。 代理监视其资源使用情况和监视事件的资源使用情况，以保持在管理员指定的资源预算（策略）内，例如通过修改正在运行的查询和/或监视参数。 控制器接收监控结果，分析结果，并根据需要对服务器运行和监控采取行动。 控制器可以动态地更新代理的查询，监视参数和/或监视的数据后处理操作。 控制器可以发出警报和报告，包括指示两个或多个服务器之间的服务器间问题的警报。

公开(公告)号：US20110320586A1

公开(公告)日：2011-12-29

申请号：US12825336

申请日：2010-06-29

申请人： David A. Maltz ,  Jonathan David Goldstein ,  Albert Greenberg ,  Charles Loboz ,  Parveen K. Patel

发明人： David A. Maltz ,  Jonathan David Goldstein ,  Albert Greenberg ,  Charles Loboz ,  Parveen K. Patel

IPC分类号： G06F15/16

CPC分类号： H04L43/0876 ,  G06F9/5027 ,  G06F11/3006 ,  G06F11/3072 ,  G06F11/3093 ,  G06F11/3409 ,  G06F11/3495 ,  G06F17/30864 ,  G06F2201/88 ,  G06F2209/5013 ,  H04L43/0817

摘要： Described is a server monitoring technology that is scalable to large numbers of servers, e.g., in a datacenter. Agents on servers run queries to monitor data sources for that server, such as performance counters and other events. The agents monitor their resource usage and those of monitored events to stay within an administrator-specified resource budget (policy), e.g., by modifying the running queries and/or monitoring parameters. A controller receives results of the monitoring, analyzes the results, and takes action as needed with respect to server operation and monitoring. The controller may dynamically update an agent's queries, monitoring parameters and/or monitored data post-processing operations. The controller may issue alerts and reports, including alerts indicative of inter-server problems between two or more servers.

摘要翻译： 描述了可扩展到大量服务器的服务器监控技术，例如在数据中心中。 服务器上的代理运行查询以监视该服务器的数据源，例如性能计数器和其他事件。 代理监视其资源使用情况和监视事件的资源使用情况，以保持在管理员指定的资源预算（策略）内，例如通过修改正在运行的查询和/或监视参数。 控制器接收监控结果，分析结果，并根据需要对服务器运行和监控采取行动。 控制器可以动态地更新代理的查询，监视参数和/或监视的数据后处理操作。 控制器可以发出警报和报告，包括指示两个或多个服务器之间的服务器间问题的警报。

公开(公告)号：US20120166417A1

公开(公告)日：2012-06-28

申请号：US12977107

申请日：2010-12-23

申请人： Badrish Chandramouli ,  Jonathan David Goldstein ,  Peter Alfred Zabback ,  David Eugene Maier ,  Di Wang

发明人： Badrish Chandramouli ,  Jonathan David Goldstein ,  Peter Alfred Zabback ,  David Eugene Maier ,  Di Wang

IPC分类号： G06F7/00

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

摘要： Described herein are technologies pertaining to migrating state information of operators in a first continuous query plan to a second continuous query plan in an asynchronous manner, such that the first continuous query plan need not cease executing during the migrating of the state information. State information pertaining to stateful operators, such as join operators, is migrated from the first continuous query plan to the second continuous query plan by way of a transformation plan. State matching is utilized to generate the transformation plan.

摘要翻译： 这里描述的是涉及将第一连续查询计划中的运营商的状态信息以异步方式迁移到第二连续查询计划的技术，使得在迁移状态信息期间第一连续查询计划不需要停止执行。 通过转换方案，将有状态运算符（例如加入运算符）的状态信息从第一个连续查询计划迁移到第二个连续查询计划。 利用状态匹配来生成转换计划。

公开(公告)号：US07739262B2

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

申请号：US10805083

申请日：2004-03-19

申请人： Per-Åke Larson ,  Jonathan David Goldstein ,  Raghu Ramakrishnan ,  Hongfei Guo

发明人： Per-Åke Larson ,  Jonathan David Goldstein ,  Raghu Ramakrishnan ,  Hongfei Guo

IPC分类号： G06F17/30

CPC分类号： G06F17/30522

摘要： Currency and consistency requirements are specified as part of a query against a database that may contain replicated data that is updated asynchronously and therefore may not be completely up to date. The database system constructs query execution plans that include an input selection operator that verifies the currency of a replica and selects a subplan using the replica for execution only when the replica meets the query's currency constraints. It checks possible query execution plans at construction time against the query's consistency constraints and any plans that may produce a result not meeting the consistency constraints are rejected. In this way, the query result is guaranteed to satisfy the query's currency and consistency requirements.

摘要翻译： 货币和一致性要求被指定为针对数据库的查询的一部分，数据库可能包含异步更新的复制数据，因此可能不完全是最新的。 数据库系统构建查询执行计划，其中包括验证副本的货币的输入选择运算符，并且只有当副本符合查询的货币约束时才使用副本才能执行子计划。 它可以根据查询的一致性约束在施工时检查可能的查询执行计划，并且拒绝可能产生不符合一致性约束的结果的任何计划。 以这种方式，查询结果保证满足查询的货币和一致性要求。