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

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

公开(公告)号：US09043764B2

公开(公告)日：2015-05-26

申请号：US13043952

申请日：2011-03-09

申请人： Anand Ranganathan ,  Anton V. Riabov ,  Octavian Udrea

发明人： Anand Ranganathan ,  Anton V. Riabov ,  Octavian Udrea

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

CPC分类号： G06F17/30563 ,  G06F17/30592

摘要： Techniques for automatically partitioning a multi-platform data transform flow graph to one or more target output platforms are provided. The techniques include performing type inference on a transform graph, wherein the transform graph comprises one or more data transforms, automatically partitioning the transform graph to one or more target output platforms based on one or more policies, performing an optimization of the partitioned transform graph, and generating code, from the partitioned transform graph, for each set of the one or more data transforms based on the one or more target output platforms.

摘要翻译： 提供了将多平台数据转换流图自动分割到一个或多个目标输出平台的技术。 所述技术包括在变换图上执行类型推理，其中所述变换图包括一个或多个数据变换，基于一个或多个策略自动将所述变换图分解成一个或多个目标输出平台，执行所述分割变换图的优化， 以及基于所述一个或多个目标输出平台从所述分割变换图生成针对所述一个或多个数据变换的每组的代码。

公开(公告)号：US08239828B2

公开(公告)日：2012-08-07

申请号：US11971056

申请日：2008-01-08

申请人： Zhen Liu ,  Anton V. Riabov

发明人： Zhen Liu ,  Anton V. Riabov

IPC分类号： G06F9/44

CPC分类号： G06F11/3664 ,  G06F11/3672

摘要： A method for recovering from software failures, includes: receiving failure information that identifies a failing component of a first processing graph; modifying a planning domain that includes a plurality of component descriptions according to the failure information; and composing a second processing graph by using the modified planning domain so that the second processing graph does not include the failing component.

摘要翻译： 一种用于从软件故障中恢复的方法包括：接收识别第一处理图的故障组件的故障信息; 根据故障信息修改包括多个组件描述的规划域; 以及通过使用修改的规划域来构成第二处理图，使得第二处理图不包括故障组件。

公开(公告)号：US08141160B2

公开(公告)日：2012-03-20

申请号：US11493321

申请日：2006-07-26

申请人： Kay S. Anderson ,  Alexandre V. Evfimievski ,  Mark D. Feblowitz ,  Genady Grabarnik ,  Nagui Halim ,  Zhen Liu ,  Ralf Rantzau ,  Anton V. Riabov ,  Angela Schuett ,  Ramakrishnan Srikant ,  Grant Wagner

发明人： Kay S. Anderson ,  Alexandre V. Evfimievski ,  Mark D. Feblowitz ,  Genady Grabarnik ,  Nagui Halim ,  Zhen Liu ,  Ralf Rantzau ,  Anton V. Riabov ,  Angela Schuett ,  Ramakrishnan Srikant ,  Grant Wagner

IPC分类号： H04L29/06

CPC分类号： G06Q50/26 ,  G06Q10/06 ,  G06Q10/0635

摘要： System and methods are provided for managing and mitigating privacy risks in a system having a network of processing elements. According to one method, there is receive a request for at least one output product from the system. The request includes a set of privacy parameters. At least one set of workflow generating strategies are created that results in the output product having a privacy risk value below a predefined threshold. At least one of the workflow generating strategies is deployed for automatically producing the at least one output product.

摘要翻译： 提供了系统和方法来管理和减轻具有处理元件网络的系统中的隐私风险。 根据一种方法，从系统接收至少一个输出产品的请求。 该请求包括一组隐私参数。 创建至少一组工作流生成策略，导致输出产品的隐私风险值低于预定阈值。 至少一个工作流生成策略被部署用于自动产生至少一个输出产品。

公开(公告)号：US08117233B2

公开(公告)日：2012-02-14

申请号：US11748216

申请日：2007-05-14

申请人： Zhen Liu ,  Anand Ranganathan ,  Anton V. Riabov

发明人： Zhen Liu ,  Anand Ranganathan ,  Anton V. Riabov

IPC分类号： G06F7/00

CPC分类号： G06Q10/10

摘要： A method for modeling a web service operation, includes: defining an input message pattern that describes input requirements of a web service operation, wherein the input message pattern includes a set of variables representing data elements that must be contained in a message input to the web service operation, and a graph pattern that semantically describes the data elements that must be contained in the message input to the web service operation; and defining an output message pattern that describes an output message of the web service operation, wherein the output message pattern includes a set of variables and exemplars that represent data elements contained in the output message, and a graph pattern that semantically describes the data elements contained in the output message.

摘要翻译： 一种用于建模Web服务操作的方法，包括：定义描述web服务操作的输入要求的输入消息模式，其中所述输入消息模式包括一组变量，所述变量表示必须包含在输入到web的消息中的数据元素 服务操作和语义上描述必须包含在输入到Web服务操作的消息中的数据元素的图形模式; 以及定义描述所述web服务操作的输出消息的输出消息模式，其中所述输出消息模式包括表示所述输出消息中包含的数据元素的一组变量和示例，以及语义上描述包含的数据元素的图形模式 在输出消息中。

公开(公告)号：US08098248B2

公开(公告)日：2012-01-17

申请号：US11695457

申请日：2007-04-02

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

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

IPC分类号： G06T11/20

CPC分类号： G06F17/30516

摘要： A method for modeling components of a stream processing application, includes: defining an input message pattern of a processing element, wherein the input message pattern includes variables representing data objects that must be included in a message input to the processing element, and a graph pattern that semantically describes the data objects that must be included in the message input to the processing element; and defining an output message pattern of the processing element, wherein the output message pattern includes variables and new data objects, the variables and new data objects representing data objects that must be included in a message output from the processing element, and a graph pattern that semantically describes the data objects in the message output from the processing element.

摘要翻译： 一种用于对流处理应用的组件进行建模的方法，包括：定义处理元件的输入消息模式，其中输入消息模式包括表示必须包括在输入到处理元件的消息中的数据对象的变量，以及图形模式 语义上描述必须包括在输入到处理元件的消息中的数据对象; 并且定义所述处理元件的输出消息模式，其中所述输出消息模式包括变量和新数据对象，所述变量和新数据对象表示必须包括在从所述处理元件输出的消息中的数据对象，以及图形模式， 语义上描述从处理元素输出的消息中的数据对象。

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

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

公开(公告)号：US20110004863A1

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

申请号：US11695349

申请日：2007-04-02

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

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

IPC分类号： G06F9/44 ,  G06N5/02

CPC分类号： G08G1/04 ,  G08G1/09

摘要： A method for assembling processing graphs in an information processing system, includes: performing, in an offline manner, translating a plurality of component descriptions into a planning language and performing reasoning on the plurality of component descriptions during the translation; and performing, in an online manner, receiving a processing request that specifies a desired processing outcome; translating the processing request into a planning goal; and assembling a plurality of processing graphs, each of the processing graphs including a plurality of the translated and reasoned components that satisfy the desired processing outcome.

摘要翻译： 一种用于在信息处理系统中组装处理图的方法，包括：以离线方式执行将多个组件描述转换成规划语言，并在翻译过程中对多个组件描述执行推理; 并且以在线方式执行接收指定所需处理结果的处理请求; 将处理请求转换为规划目标; 以及组合多个处理图，每个处理图包括满足期望处理结果的多个翻译和推理组件。

公开(公告)号：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并且在并发计算系统中部署流处理流以产生输出。

公开(公告)号：US07834875B2

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

申请号：US11695487

申请日：2007-04-02

申请人： Zhen Liu ,  Anand Ranganathan ,  Anton V. Riabov

发明人： Zhen Liu ,  Anand Ranganathan ,  Anton V. Riabov

IPC分类号： G09T11/20

CPC分类号： G06F8/00 ,  G06F9/4494

摘要： A method for assembling stream processing graphs in a stream processing system, includes: performing, in an offline manner, translating a plurality of processing element and data source descriptions into a planning language and performing reasoning on the plurality of processing element and data source descriptions during the translation; and performing, in an online manner, receiving a processing request that specifies a desired processing outcome; translating the processing request into a planning goal; and assembling a plurality of stream processing graphs, each of the processing graphs including a plurality of the translated and reasoned processing elements or data sources that satisfy the desired processing outcome.

摘要翻译： 一种用于在流处理系统中组合流处理图的方法，包括：以离线方式执行将多个处理元素和数据源描述转换成规划语言，并在多个处理元素和数据源描述上执行推理 译文; 并且以在线方式执行接收指定所需处理结果的处理请求; 将处理请求转换为规划目标; 以及组合多个流处理图，每个处理图包括满足期望处理结果的多个经翻译和推理的处理元件或数据源。