公开(公告)号：US20080228443A1

公开(公告)日：2008-09-18

申请号：US11926208

申请日：2007-10-29

申请人： KAY S. ANDERSON ,  Joseph P. Bigus ,  Eric Bouillet ,  Parijat Dube ,  Zhen Liu ,  Dimitrios Pendarakis

发明人： KAY S. ANDERSON ,  Joseph P. Bigus ,  Eric Bouillet ,  Parijat Dube ,  Zhen Liu ,  Dimitrios Pendarakis

IPC分类号： G06F19/00

CPC分类号： G06F11/263

摘要： A system, method, and computer program product for benchmarking a stream processing system are disclosed. The method comprises generating a plurality of correlated test streams. A semantically related data set is embedded within each of the test streams in the plurality of correlated test streams. The plurality of correlated test streams is provided to at least one stream processing system. A summary is generated for each of the semantically related embedded data sets. A common identifier, which is transparent to the system being tested, is embedded within each stream in the plurality of correlated test streams. The common identifier is extracted from the output data set generated by the stream processing system. At least one of the stored copies of the summaries and the common identifier are compared to an output data set including a set of zero or more correlation results generated by the stream processing system.

摘要翻译： 公开了一种用于基准流处理系统的系统，方法和计算机程序产品。 该方法包括生成多个相关测试流。 语义相关的数据集嵌入在多个相关测试流中的每个测试流内。 多个相关测试流被提供给至少一个流处理系统。 为每个语义相关的嵌入式数据集生成一个摘要。 对被测系统透明的公共标识符嵌入在多个相关测试流中的每个流内。 从流处理系统生成的输出数据集中提取公共标识符。 将总结的存储副本和公共标识符中的至少一个与包括由流处理系统生成的一组零个或多个相关结果的输出数据集进行比较。

公开(公告)号：US20090024358A1

公开(公告)日：2009-01-22

申请号：US12140418

申请日：2008-06-17

申请人： KAY S. ANDERSON ,  Joseph P. Bigus ,  Eric Bouillet ,  Parijat Dube ,  Zhen Liu ,  Dimitrios Pendarakis

发明人： KAY S. ANDERSON ,  Joseph P. Bigus ,  Eric Bouillet ,  Parijat Dube ,  Zhen Liu ,  Dimitrios Pendarakis

IPC分类号： G06F15/00

CPC分类号： G06F11/263

摘要： A system, method, and computer program product for benchmarking a stream processing system are disclosed. The method comprises generating a plurality of correlated test streams. A semantically related data set is embedded within each of the test streams in the plurality of correlated test streams. The plurality of correlated test streams is provided to at least one stream processing system. A summary is generated for each of the semantically related embedded data sets. A common identifier, which is transparent to the system being tested, is embedded within each stream in the plurality of correlated test streams. The common identifier is extracted from the output data set generated by the stream processing system. At least one of the stored copies of the summaries and the common identifier are compared to an output data set including a set of zero or more correlation results generated by the stream processing system.

摘要翻译： 公开了一种用于基准流处理系统的系统，方法和计算机程序产品。 该方法包括生成多个相关测试流。 语义相关的数据集嵌入在多个相关测试流中的每个测试流内。 多个相关测试流被提供给至少一个流处理系统。 为每个语义相关的嵌入式数据集生成一个摘要。 对被测系统透明的公共标识符嵌入在多个相关测试流中的每个流内。 从流处理系统生成的输出数据集中提取公共标识符。 将总结的存储副本和公共标识符中的至少一个与包括由流处理系统生成的一组零个或多个相关结果的输出数据集进行比较。

公开(公告)号：US20080235691A1

公开(公告)日：2008-09-25

申请号：US12114105

申请日：2008-05-02

申请人： KAY S. ANDERSON ,  Joseph Phillip Bigus ,  Mark David Feblowitz ,  Genady Ya. Grabarnik ,  Nagui Halim ,  Zhen Liu ,  Anton V. Riabov

发明人： KAY S. ANDERSON ,  Joseph Phillip Bigus ,  Mark David Feblowitz ,  Genady Ya. Grabarnik ,  Nagui Halim ,  Zhen Liu ,  Anton V. Riabov

IPC分类号： G06F9/46

CPC分类号： G06Q10/06

摘要： An automatic planning system is provided for stream processing workflow composition. End users provide requests to the automatic planning system. The requests are goal-based problems to be solved by the automatic planning system, which then generates plan graphs to form stream processing applications. A scheduler deploys and schedules the stream processing applications for execution within an operating environment. The operating environment then returns the results to the end users.

摘要翻译： 为流处理工作流组合提供了自动计划系统。 最终用户向自动规划系统提供请求。 这些请求是基于目标的问题，由自动计划系统解决，然后生成计划图以形成流处理应用程序。 调度程序部署和调度流处理应用程序以在操作环境中执行。 然后，操作环境将结果返回给最终用户。