公开(公告)号：US08290939B2

公开(公告)日：2012-10-16

申请号：US12827419

申请日：2010-06-30

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

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

IPC分类号： G06F7/00

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.

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

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

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

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

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

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

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

公开(公告)号：US20100288689A1

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

申请号：US12438505

申请日：2006-08-22

申请人： Liang Zhu ,  Wen-Tso Liu ,  Hanhua Feng ,  Hong Miao Ji ,  William Cheng Yong Teo ,  Ramana Murthy Badam

发明人： Liang Zhu ,  Wen-Tso Liu ,  Hanhua Feng ,  Hong Miao Ji ,  William Cheng Yong Teo ,  Ramana Murthy Badam

IPC分类号： B81B1/00 ,  B01D29/03 ,  B01D29/50

CPC分类号： B01D61/147 ,  B01L3/5027 ,  G01N1/4077

摘要： A microfluidic filtration unit for trapping particles of a predetermined nominal size present in a fluid is provided. The unit comprises a fluid chamber connected to an inlet for introducing the fluid to be filtered and an outlet for discharging filtered fluid, a filtration barrier arranged within the fluid chamber, said filtration barrier comprising a plurality of pillars arranged substantially perpendicular to the path of fluid flow when fluid is introduced into the fluid chamber, said pillars being aligned to form at least one row extending across said path of fluid flow, wherein each of said at least one row of pillars in the filtration barrier comprises at least one fine filtration section comprising a group of pillars that are spaced apart to prevent particles to be filtered from the fluid from moving between adjacent pillars, and at least one coarse filtration section comprising a group of pillars that are spaced apart to permit the movement of particles between adjacent pillars.

摘要翻译： 提供了用于捕获存在于流体中的预定公称尺寸的微粒的微流体过滤单元。 该单元包括连接到入口的流体室，用于引入要过滤的流体和用于排出过滤流体的出口，布置在流体室内的过滤阻挡层，所述过滤屏障包括基本上垂直于流体路径布置的多个柱 当流体被引入到流体室中时，所述柱被对准以形成跨越所述流体流动路径延伸的至少一排，其中所述过滤阻挡层中的所述至少一排柱中的每一个包括至少一个精细过滤部分，其包括 间隔开的一组支柱，以防止颗粒从流体中过滤，以在相邻的柱之间移动;以及至少一个粗过滤部分，其包括间隔开的一组支柱，以允许颗粒在相邻支柱之间移动。

公开(公告)号：US07889651B2

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

申请号：US11758706

申请日：2007-06-06

申请人： Hanhua Feng ,  Zhen Liu ,  Honghui Xia ,  Li Zhang

发明人： Hanhua Feng ,  Zhen Liu ,  Honghui Xia ,  Li Zhang

IPC分类号： G01R31/08

CPC分类号： G06F9/5066 ,  G06F9/5038

摘要： Methods and apparatus operating in a stream processing network perform load shedding and dynamic resource allocation so as to meet a pre-determined utility criterion. Load shedding is envisioned as an admission control problem encompassing source nodes admitting workflows into the stream processing network. A primal-dual approach is used to decompose the admission control and resource allocation problems. The admission control operates as a push-and-pull process with sources pushing workflows into the stream processing network and sinks pulling processed workflows from the network. A virtual queue is maintained at each node to account for both queue backlogs and credits from sinks. Nodes of the stream processing network maintain shadow prices for each of the workflows and share congestion information with neighbor nodes. At each node, resources are devoted to the workflow with the maximum product of downstream pressure and processing rate, where the downstream pressure is defined as the backlog difference between neighbor nodes. The primal-dual controller iteratively adjusts the admission rates and resource allocation using local congestion feedback. The iterative controlling procedure further uses an interior-point method to improve the speed of convergence towards optimal admission and allocation decisions.

公开(公告)号：US06667189B1

公开(公告)日：2003-12-23

申请号：US10243906

申请日：2002-09-13

申请人： Zhe Wang ,  Qingxin Zhang ,  Hanhua Feng

发明人： Zhe Wang ,  Qingxin Zhang ,  Hanhua Feng

IPC分类号： H01L2100

CPC分类号： H04R19/005 ,  Y10T29/49005

摘要： A silicon condenser microphone is described. The silicon condenser microphone of the present invention comprises a perforated backplate comprising a portion of a single crystal silicon substrate, a support structure formed on the single crystal silicon substrate, and a floating silicon diaphragm supported at its edge by the support structure and lying parallel to the perforated backplate and separated from the perforated backplate by an air gap.

摘要翻译： 描述了硅电容麦克风。 本发明的硅电容麦克风包括一个多孔背板，它包括单晶硅衬底的一部分，形成在单晶硅衬底上的一个支撑结构，以及一个浮动硅隔膜，其支撑结构在其边缘平行于 穿孔背板并通过气隙与多孔背板隔开。

公开(公告)号：US20140067908A1

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

申请号：US13469423

申请日：2012-05-11

申请人： Hanhua Feng ,  Anton Viktorovich Riabov

发明人： Hanhua Feng ,  Anton Viktorovich Riabov

IPC分类号： H04L29/08

CPC分类号： H04L67/26 ,  H04L45/20 ,  H04L45/28 ,  H04L67/325

摘要： Systems, methods, and products for pull data transfer in a request-response model are provided herein. One aspect provides for generating output data utilizing at least one data generation station; and communicating via the at least one data generation station output data related to at least one data request received from at least one data requesting station responsive to at least one criterion, the at least one criterion comprising one of expiration of a time period or generation of a threshold amount of output data. Other embodiments and aspects are also described herein.

摘要翻译： 本文提供了在请求 - 响应模型中拉数据传输的系统，方法和产品。 一方面提供了利用至少一个数据生成站产生输出数据的方法; 以及响应于至少一个标准，经由所述至少一个数据生成站输出与从至少一个数据请求站接收的至少一个数据请求相关的数据，所述至少一个标准包括一个时间段的到期或生成 输出数据的阈值量。 本文还描述了其它实施例和方面。