-
公开(公告)号：US20120047467A1
公开(公告)日：2012-02-23
申请号：US12857790
申请日：2010-08-17
申请人： Michael D. Pfeifer , Jingdong Sun
发明人： Michael D. Pfeifer , Jingdong Sun
CPC分类号： G06F11/3051 , G06F11/3006
摘要： A port compatibility connection engine for a large scale stream processing framework is provided. The port compatibility management unit analyzes port definitions of processing elements (PEs) to validate interconnectivity between said elements. In particular, the port compatibility management unit determines the ability of the PEs to produce and/or consume data streams based on the data stream schema definitions specified on the PE ports. In addition, the port compatibility management unit analyzes security, scope, persistence, and other factors that impact interconnectivity. The port compatibility management unit generates a connection topology snapshot based on the above analysis and identifies the combination of PEs that cannot interconnect and provides the information in an output format that allows for visualization, filtering, and automatic fix capability.
摘要翻译： 提供了一种用于大规模流处理框架的端口兼容性连接引擎。 端口兼容性管理单元分析处理元件（PE）的端口定义，以验证所述元件之间的互连性。 特别地，端口兼容性管理单元基于在PE端口上指定的数据流模式定义来确定PE产生和/或消耗数据流的能力。 此外，端口兼容性管理单元分析影响互连性的安全性，范围，持续性等因素。 端口兼容性管理单元基于上述分析生成连接拓扑快照，并标识不能互连的PE的组合，并以允许可视化，过滤和自动修复功能的输出格式提供信息。
-
公开(公告)号：US08600976B2
公开(公告)日：2013-12-03
申请号：US13218502
申请日：2011-08-26
IPC分类号： G06F7/00
CPC分类号： G06F9/5011 , G06F9/5022
摘要： Techniques are disclosed for invalidating, at one or more processing elements, data streams containing data tuples. A plurality of tuples is received via a data stream, whereupon the data stream is determined to be invalid based on at least one tuple in the plurality of tuples. The data stream is then invalidated, and a message is issued that causes one or more data streams included in the stream-based computing system and related to the invalidated data stream to also be invalidated.
摘要翻译： 公开了在一个或多个处理元件使包含数据元组的数据流无效的技术。 经由数据流接收多个元组，基于多个元组中的至少一个元组，确定数据流无效。 然后，数据流无效，并且发出使得包括在基于流的计算系统中并且与无效数据流相关的一个或多个数据流也被无效的消息。
-
公开(公告)号：US08732300B2
公开(公告)日：2014-05-20
申请号：US12987335
申请日：2011-01-10
IPC分类号： G06F15/173 , G06F15/16 , H04L12/24 , H04L29/08 , H04L29/06
CPC分类号： H04L29/08072 , G06F17/30516 , H04L29/06 , H04L41/12 , H04L41/22
摘要： Methods and systems for monitoring a stream application are disclosed. The stream application is composed from a plurality of processing elements executing on one or more compute nodes. A graphical user interface display presents a user with at least a portion of an operator graph in a running stream application. The operator graph represents the plurality of processing elements, and links between processing elements, corresponding to a flow of data tuples through the stream application. A monitoring application then monitors user interactions with the presentation of the portion of the operator graph on the graphical user interface display and identifies at least a first modification to the stream application based on a processing state of the stream application and the monitored user interactions.
摘要翻译： 公开了用于监视流应用的方法和系统。 流应用由在一个或多个计算节点上执行的多个处理元件组成。 图形用户界面显示器向用户呈现运行流应用中的运算符图的至少一部分。 运算符图表示多个处理元件，以及处理元件之间的链接，对应于通过流应用的数据元组流。 监视应用程序然后基于图形用户界面显示器上的操作员图形的部分显示来监视用户交互，并且基于流应用程序的处理状态和所监视的用户交互来识别流应用程序的至少第一修改。
-
公开(公告)号：US08327337B2
公开(公告)日：2012-12-04
申请号：US12956424
申请日：2010-11-30
CPC分类号： G06F11/362
摘要： Techniques are described for debugging a processing element (or elements) in a stream based database application in a manner that reduces the impact of debugging the processing element (or elements) on the overall running environment by selectively fusing (or un-fusing) processing elements running on a group of compute nodes. In addition to fusing and un-fusing processing elements or otherwise modifying a state of the stream application, a debugging application and stream manager may modify data flows within the application stream in a variety of ways to minimize any disruption resulting from a debugging session.
摘要翻译： 描述了用于以基于流的数据库应用程序调试处理元件（或元件）的技术，其方法是通过选择性地熔化（或取消融合）处理元件来减少调试处理元件（或元件）对整个运行环境的影响 运行在一组计算节点上。 调试应用程序和流管理器除了融合和取消定制处理元件或以其他方式修改流应用程序的状态之外，还可以以各种方式修改应用程序流内的数据流，以最小化调试会话导致的任何中断。
-
公开(公告)号：US09396157B2
公开(公告)日：2016-07-19
申请号：US13218545
申请日：2011-08-26
IPC分类号： G06F15/173 , G06F17/30 , H04L12/26 , H04L29/06 , H04L12/24
CPC分类号： G06F15/173 , G06F17/30516 , H04L41/22 , H04L43/08 , H04L43/12 , H04L65/607
摘要： Techniques are disclosed for calculating performance metrics associated with a data stream. A processing element configured to process data tuples flowing through a stream-based computing system receives data tuples via the data stream. Each of the one or more tuples is processed at the processing element, and each of the one or more tuples are associated with metadata that includes information related to the processing of the tuple by the processing element. Performance metrics are then calculated for the data stream based on the metadata associated with the one or more tuples.
摘要翻译： 公开了用于计算与数据流相关联的性能度量的技术。 被配置为处理流过基于流的计算系统的数据元组的处理元件经由数据流接收数据元组。 一个或多个元组中的每一个在处理元件处被处理，并且一个或多个元组中的每个元组与包括与处理元件的元组的处理相关的信息的元数据相关联。 然后基于与一个或多个元组相关联的元数据为数据流计算性能度量。
-
公开(公告)号：US20130054538A1
公开(公告)日：2013-02-28
申请号：US13218502
申请日：2011-08-26
IPC分类号： G06F17/30
CPC分类号： G06F9/5011 , G06F9/5022
摘要： Techniques are disclosed for invalidating, at one or more processing elements, data streams containing data tuples. A plurality of tuples is received via a data stream, whereupon the data stream is determined to be invalid based on at least one tuple in the plurality of tuples. The data stream is then invalidated, and a message is issued that causes one or more data streams included in the stream-based computing system and related to the invalidated data stream to also be invalidated.
摘要翻译： 公开了在一个或多个处理元件使包含数据元组的数据流无效的技术。 经由数据流接收多个元组，因此基于多个元组中的至少一个元组将数据流确定为无效。 然后，数据流无效，并且发出使得包括在基于流的计算系统中并且与无效数据流相关的一个或多个数据流也被无效的消息。
-
公开(公告)号：US20080140622A1
公开(公告)日：2008-06-12
申请号：US11609612
申请日：2006-12-12
IPC分类号： G06F17/30
CPC分类号： G06F16/24542
摘要： Methods, apparatus, and products are disclosed for displaying explain data for a SQL query of a database that include: executing, by a SQL execution module, a SQL query in a database management system; accumulating, by the SQL execution module, actual run time data for the SQL query while executing the SQL query; and displaying, by an explain module, explain data for the SQL query while executing the SQL query, including displaying the accumulated actual run time data for the SQL query as part of the explain data for the SQL query.
摘要翻译： 公开了用于显示数据库的SQL查询的说明数据的方法，装置和产品，其包括：由SQL执行模块执行数据库管理系统中的SQL查询; 在执行SQL查询时，由SQL执行模块累积SQL查询的实际运行时数据; 并且由解释模块显示在执行SQL查询时解释SQL查询的数据，包括显示SQL查询的累积实际运行时数据作为SQL查询的解释数据的一部分。
-
-
-
-
-
-
搜索结果
7 条记录 (耗时 0.022 秒)
