公开(公告)号：US20100318768A1

公开(公告)日：2010-12-16

申请号：US12485592

申请日：2009-06-16

申请人： Eric Bouillet ,  Hanhua Feng ,  Zhen Liu ,  Anton V. Riabov

发明人： Eric Bouillet ,  Hanhua Feng ,  Zhen Liu ,  Anton V. Riabov

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

CPC分类号： G06Q10/06 ,  G06F9/4494

摘要： An apparatus, including a memory device for storing a program, and a processor in communication with the memory device, the processor operative with the program to facilitate design of a stream processing flow that satisfies an objective, wherein the stream processing flow includes at least three processing groups, wherein a first processing group includes a data source and an operator, a second processing group includes a data source and an operator and a third processing group includes a join operator at its input and another operator, wherein data inside each group is organized by channels and each channel is a sequence of data, wherein an operator producing a data channel does not generate new data for the channel until old data of the channel is received by all other operators in the same group, and wherein data that flows from the first and second groups to the third group is done asynchronously and is stored in a queue if not ready for processing by an operator of the third group, and deploy the stream processing flow in a concurrent computing system to produce an output.

摘要翻译： 一种装置，包括用于存储程序的存储装置和与存储装置通信的处理器，所述处理器与程序一起操作以便于满足目标的流处理流程的设计，其中流处理流程包括至少三个 处理组，其中第一处理组包括数据源和操作者，第二处理组包括数据源和操作者，第三处理组在其输入处包括加入运算符和另一运算符，其中组内每个组内的数据被组织 每个信道是一个数据序列，其中产生数据信道的运算符不产生信道的新数据，直到信道的旧数据被同一组中的所有其他运算符接收，并且其中从 第一组和第二组到第三组是异步完成的，如果没有准备好进行处理，则由第三组的运算符存储在队列中 p并且在并发计算系统中部署流处理流以产生输出。

公开(公告)号：US08380965B2

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

申请号：US12485592

申请日：2009-06-16

申请人： Eric Bouillet ,  Hanhua Feng ,  Zhen Liu ,  Anton V. Riabov

发明人： Eric Bouillet ,  Hanhua Feng ,  Zhen Liu ,  Anton V. Riabov

IPC分类号： G06F9/00

CPC分类号： G06Q10/06 ,  G06F9/4494

摘要： An apparatus to facilitate design of a stream processing flow that satisfies an objective, wherein the flow includes at least three processing groups, wherein a first processing group includes a data source and an operator, a second processing group includes a data source and an operator and a third processing group includes a join operator at its input and another operator, wherein data inside each group is organized by channels and each channel is a sequence of data, wherein an operator producing a data channel does not generate new data for the channel until old data of the channel is received by all other operators in the same group, and wherein data that flows from the first and second groups to the third group is done asynchronously and is stored in a queue if not ready for processing by an operator of the third group.

摘要翻译： 一种便于设计满足目标的流处理流的装置，其中所述流包括至少三个处理组，其中第一处理组包括数据源和操作者，第二处理组包括数据源和操作符， 第三处理组包括其输入端的加入运算符和另一运算符，其中每组内的数据由信道组织，并且每个信道是数据序列，其中产生数据信道的运算符不会在该信道之前生成用于该信道的新数据，直到旧 信道的数据由同一组中的所有其他运营商接收，并且其中从第一组和第二组流向第三组的数据是异步完成的，并且如果没有准备好被第三组的运营商处理，则将其存储在队列中 组。

公开(公告)号：US09104506B2

公开(公告)日：2015-08-11

申请号：US12626745

申请日：2009-11-27

申请人： Eric Bouillet ,  Mark D. Feblowitz ,  Hanhua Feng ,  Anand Ranganathan ,  Anton V. Riabov ,  Octavian Udrea

发明人： Eric Bouillet ,  Mark D. Feblowitz ,  Hanhua Feng ,  Anand Ranganathan ,  Anton V. Riabov ,  Octavian Udrea

IPC分类号： G06F9/445 ,  G06F9/54

CPC分类号： G06F9/541

摘要： A method and computer program product for assembling and deploying multi-platform flow based applications. An information processing flow that produces a result is assembled, the information processing flow includes components connected by data links, a component includes software code that describes at least one of an input constraint or an output constraint of the component, and at least two of the components are deployable on different computing platforms. The information processing flow is partitioned into sub-flows, such that for each sub-flow every component in the sub-flow is deployable on the same computing platform. The sub-flows are deployed on their respective computing platforms.

摘要翻译： 一种用于组装和部署多平台流程应用程序的方法和计算机程序产品。 组合产生结果的信息处理流程，信息处理流程包括通过数据链路连接的组件，组件包括描述组件的输入约束或输出约束中的至少一个的软件代码，以及至少两个 组件可部署在不同的计算平台上。 信息处理流被划分为子流，使得对于每个子流，子流中的每个组件可部署在相同的计算平台上。 子流部署在各自的计算平台上。

公开(公告)号：US20110302196A1

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

申请号：US12827419

申请日：2010-06-30

申请人： Eric Bouillet ,  Hanhua Feng ,  Anton V. Riabov

发明人： Eric Bouillet ,  Hanhua Feng ,  Anton V. Riabov

IPC分类号： G06F17/30

CPC分类号： G06F17/30516

摘要： In a method for visualizing query results in stream processing systems, a visualization service receives a query from a client to visualize data in a stream processing application. The query is sent from the visualization service to a query-able operator of the stream processing application. At the query-able operator, an operation is performed using history data in the query-able operator to produce a first result that satisfies the query and the first result is sent to the visualization service. At the query-able operator, another operation is performed using new data received by the query-able operator to produce a second result that satisfies the query and the second result is sent to the visualization service. The first and second results are output from the visualization service to the client.

摘要翻译： 在用于在流处理系统中可视化查询结果的方法中，可视化服务从客户端接收查询以在流处理应用中可视化数据。 查询从可视化服务发送到流处理应用程序的可查询操作员。 在可查询操作员处，使用可查询操作符中的历史数据执行操作，以产生满足查询的第一个结果，并将第一个结果发送给可视化服务。 在可查询操作员处，使用由可查询操作者接收的新数据执行另一操作，以产生满足查询的第二结果，并将第二结果发送给可视化服务。 第一和第二个结果从可视化服务输出到客户端。

公开(公告)号：US20110131557A1

公开(公告)日：2011-06-02

申请号：US12626745

申请日：2009-11-27

申请人： Eric Bouillet ,  Mark D. Feblowitz ,  Hanhua Feng ,  Anand Ranganathan ,  Anton V. Riabov ,  Octavian Udrea

发明人： Eric Bouillet ,  Mark D. Feblowitz ,  Hanhua Feng ,  Anand Ranganathan ,  Anton V. Riabov ,  Octavian Udrea

IPC分类号： G06F9/45

CPC分类号： G06F9/541

摘要： A method and computer program product for assembling and deploying multi-platform flow based applications. An information processing flow that produces a result is assembled, the information processing flow includes components connected by data links, a component includes software code that describes at least one of an input constraint or an output constraint of the component, and at least two of the components are deployable on different computing platforms. The information processing flow is partitioned into sub-flows, such that for each sub-flow every component in the sub-flow is deployable on the same computing platform. The sub-flows are deployed on their respective computing platforms.

摘要翻译： 一种用于组装和部署基于多平台流程的应用程序的方法和计算机程序产品。 组合产生结果的信息处理流程，信息处理流程包括通过数据链路连接的组件，组件包括描述组件的输入约束或输出约束中的至少一个的软件代码，以及至少两个 组件可部署在不同的计算平台上。 信息处理流被划分为子流，使得对于每个子流，子流中的每个组件可部署在相同的计算平台上。 子流部署在各自的计算平台上。

公开(公告)号：US08898624B2

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

申请号：US12114920

申请日：2008-05-05

申请人： Eric Bouillet ,  Zhen Liu ,  Anton V. Riabov

发明人： Eric Bouillet ,  Zhen Liu ,  Anton V. Riabov

IPC分类号： G06F9/44 ,  G06F17/30

CPC分类号： G06F17/30893

摘要： A method for assembling parametric information processing applications, includes: receiving a composition request; composing a processing graph for the request, wherein the processing graph represents an application that includes at least one component; identifying a deployment parameter of the component and requesting a value of the parameter; receiving the parameter value; applying the parameter value to the application; and deploying the application with the parameter value in an execution environment.

摘要翻译： 一种用于组装参数化信息处理应用的方法，包括：接收组合请求; 组成所述请求的处理图，其中所述处理图表示包括至少一个组件的应用程序; 识别组件的部署参数并请求参数的值; 接收参数值; 将参数值应用于应用程序; 并在执行环境中使用参数值部署应用程序。

公开(公告)号：US08484611B2

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

申请号：US11872385

申请日：2007-10-15

申请人： Eric Bouillet ,  Zhen Liu ,  Anton V. Riabov

发明人： Eric Bouillet ,  Zhen Liu ,  Anton V. Riabov

IPC分类号： G06F9/44

CPC分类号： G06F8/34 ,  G06Q10/06

摘要： A method for automatic composition of an information processing flow based on a user-specified processing goal, includes: selecting tags from a first plurality of tags, wherein the selected tags specify a processing goal; composing a processing graph in accordance with the processing goal; and displaying a second plurality of tags, wherein the second plurality of tags includes tags that are only relevant to the selected tags.

摘要翻译： 一种用于基于用户指定的处理目标自动组合信息处理流程的方法，包括：从第一多个标签中选择标签，其中所选择的标签指定处理目标; 根据处理目标组成处理图; 以及显示第二多个标签，其中所述第二多个标签包括仅与所选标签相关的标签。

公开(公告)号：US20100095269A1

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

申请号：US12252156

申请日：2008-10-15

申请人： Eric Bouillet ,  Mark D. Feblowitz ,  Zhen Liu ,  Anand Ranganathan ,  Anton V. Riabov

发明人： Eric Bouillet ,  Mark D. Feblowitz ,  Zhen Liu ,  Anand Ranganathan ,  Anton V. Riabov

IPC分类号： G06F9/44

CPC分类号： G06F8/36 ,  G06F8/10

摘要： A method, including: receiving a software requirement; and constructing a workflow template that can satisfy the software requirement, wherein the workflow template comprises a plurality of processing stages, wherein each processing stage includes at least one component class and each component class includes at least one component, and wherein an output of each processing stage is described by a processing goal pattern that is described by a set of tags and facets.

摘要翻译： 一种方法，包括：接收软件需求; 以及构建能够满足所述软件需求的工作流模板，其中所述工作流模板包括多个处理阶段，其中每个处理阶段包括至少一个组件类，并且每个组件类包括至少一个组件，并且其中每个处理的输出 阶段由通过一组标签和小平面描述的处理目标模式来描述。

公开(公告)号：US20090177957A1

公开(公告)日：2009-07-09

申请号：US11970262

申请日：2008-01-07

申请人： Eric Bouillet ,  Zhen Liu ,  Anton V. Riabov

发明人： Eric Bouillet ,  Zhen Liu ,  Anton V. Riabov

IPC分类号： G06F17/00

CPC分类号： G06F8/30 ,  H04L67/02 ,  H04L67/16

摘要： A method for service composition, including: receiving a tag query; composing a processing graph in accordance with the tag query, wherein the processing graph is composed by using annotated primal data and services and includes at least one of the services; and deploying the service in an execution environment.

摘要翻译： 一种用于服务组合的方法，包括：接收标签查询; 根据所述标签查询组合处理图，其中所述处理图由使用注释的原始数据和服务组成并且包括所述服务中的至少一个; 并在执行环境中部署该服务。

公开(公告)号：US20090100407A1

公开(公告)日：2009-04-16

申请号：US11872385

申请日：2007-10-15

申请人： Eric Bouillet ,  Zhen Liu ,  Anton V. Riabov

发明人： Eric Bouillet ,  Zhen Liu ,  Anton V. Riabov

IPC分类号： G06F9/44

CPC分类号： G06F8/34 ,  G06Q10/06

摘要： A method for automatic composition of an information processing flow based on a user-specified processing goal, includes: selecting tags from a first plurality of tags, wherein the selected tags specify a processing goal; composing a processing graph in accordance with the processing goal; and displaying a second plurality of tags, wherein the second plurality of tags includes tags that are only relevant to the selected tags.

摘要翻译： 一种用于基于用户指定的处理目标自动组合信息处理流程的方法，包括：从第一多个标签中选择标签，其中所选择的标签指定处理目标; 根据处理目标组成处理图; 以及显示第二多个标签，其中所述第二多个标签包括仅与所选标签相关的标签。