公开(公告)号：US08458650B2

公开(公告)日：2013-06-04

申请号：US12748633

申请日：2010-03-29

申请人： Henrique Andrade ,  Bugra Gedik ,  Gabriela Jacques da Silva ,  Kun-Lung Wu

发明人： Henrique Andrade ,  Bugra Gedik ,  Gabriela Jacques da Silva ,  Kun-Lung Wu

IPC分类号： G06F11/28 ,  G06F9/44 ,  G06F9/45 ,  G06F11/00

CPC分类号： G06F11/28 ,  G06F11/3612 ,  G06F11/3616

摘要： In one embodiment, the invention comprises partial fault tolerant stream processing applications. One embodiment of a method for implementing partial fault tolerance in a stream processing application comprising a plurality of stream operators includes: defining a quality score function that expresses how well the application is performing quantitatively, injecting a fault into at least one of the plurality of operators, assessing an impact of the fault on the quality score function, and selecting at least one partial fault-tolerant technique for implementation in the application based on the quantitative metric-driven assessment.

公开(公告)号：US08326821B2

公开(公告)日：2012-12-04

申请号：US12868344

申请日：2010-08-25

申请人： Henrique Andrade ,  Bugra Gedik ,  Martin J. Hirzel ,  Robert Soule ,  Hua Yong Wang ,  Kun-Lung Wu ,  Qiong Zou

发明人： Henrique Andrade ,  Bugra Gedik ,  Martin J. Hirzel ,  Robert Soule ,  Hua Yong Wang ,  Kun-Lung Wu ,  Qiong Zou

IPC分类号： G06F7/00 ,  G06F17/30

CPC分类号： G06F17/30516

摘要： A method of transforming relational queries of a database into on a data processing system includes receiving a series of relational queries, transforming first parts of the queries into a continuous query embodied as a streaming application, sending parameters in second parts of the queries in the series to the streaming application as a data stream, and executing the continuous query based on the received data stream to generate query results for the series of relational queries. Each query in the series includes a first part and a second part. The first parts are a pattern common to all the queries in the series and the second parts each have one or more parameters that are not common to all of the queries in the series.

摘要翻译： 将数据库的关系查询变换到数据处理系统的方法包括：接收一系列关系查询，将查询的第一部分转换成体现为流应用的连续查询，在该系列的查询的第二部分中发送参数 作为数据流的流应用，并且基于接收到的数据流执行连续查询以生成用于一系列关系查询的查询结果。 该系列中的每个查询包括第一部分和第二部分。 第一部分是系列中所有查询共同的模式，第二部分每个都有一个或多个参数，这些参数对于该系列中的所有查询都不常见。

公开(公告)号：US20120276930A1

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

申请号：US13469350

申请日：2012-05-11

申请人： Bhuvan BAMBA ,  Bugra GEDIK ,  Kun-Lung WU

发明人： Bhuvan BAMBA ,  Bugra GEDIK ,  Kun-Lung WU

IPC分类号： H04W24/00

CPC分类号： H04W4/025 ,  H04W24/08

摘要： A method for processing a first data stream specifying locations of a user at different times and a second data stream specifying values of a monitored attribute at a location of interest at different times includes: receiving a location-centric trigger specifying at least one spatial predicate condition relative to the location of interest and at least one non-spatial predicate condition relevant to the location of interest, calculating a safe region that includes locations whose probability of satisfying the spatial predicate condition falls below a first threshold, calculating a safe value container that includes values whose probability of satisfying the non-spatial predicate condition falls below a second threshold, and processing the first data stream and the second data stream against the location-centric trigger, by considering only those locations that are not contained within the safe region and only those values that are not contained within the safe value container.

公开(公告)号：US08291006B2

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

申请号：US12130043

申请日：2008-05-30

申请人： Henrique Andrade ,  Bugra Gedik ,  Kun-Lung Wu

发明人： Henrique Andrade ,  Bugra Gedik ,  Kun-Lung Wu

IPC分类号： G06F15/16

CPC分类号： G06F9/5066 ,  G06F17/30516 ,  G06F17/30545

摘要： Techniques for generating a distributed stream processing application are provided. The techniques include obtaining a declarative description of one or more data stream processing tasks, wherein the declarative description expresses at least one stream processing task, and generating one or more execution units from the declarative description of one or more data stream processing tasks, wherein the one or more execution units are deployable across one or more distributed computing nodes, and comprise a distributed data stream processing application.

摘要翻译： 提供了用于生成分布式流处理应用的技术。 这些技术包括获得一个或多个数据流处理任务的声明性描述，其中所述声明性描述表达至少一个流处理任务，并且从一个或多个数据流处理任务的声明性描述生成一个或多个执行单元，其中， 一个或多个执行单元可跨越一个或多个分布式计算节点部署，并且包括分布式数据流处理应用。

公开(公告)号：US08271409B2

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

申请号：US12061218

申请日：2008-04-02

申请人： Gang Luo ,  Kun-Lung Wu ,  Philip Shi-lung Yu

发明人： Gang Luo ,  Kun-Lung Wu ,  Philip Shi-lung Yu

IPC分类号： G06E1/00 ,  G06E3/00

CPC分类号： G06F17/30442 ,  Y10S707/99942

摘要： There are provided methods, computer program products, and systems for indexing a data stream. A method for indexing a data stream having attribute values includes the steps of parsing the data stream, and forming an index of tuples for a subset of attribute values of the data stream. The index is configured for retrieving the top-K tuples that optimize linearly weighted sums of at least some of the attribute values in the subset.

摘要翻译： 提供了用于索引数据流的方法，计算机程序产品和系统。 用于索引具有属性值的数据流的方法包括解析数据流以及为数据流的属性值的子集形成元组的索引的步骤。 索引被配置用于检索优化子集中的至少一些属性值的线性加权和的顶部K元组。

公开(公告)号：US08237393B2

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

申请号：US12565773

申请日：2009-09-24

申请人： Ling-Yu Xie ,  Kun-Lung Wu ,  Sheng-Chung Huang ,  San-Yong Yang ,  Xin-Ping Zhang ,  Jing Liu

发明人： Ling-Yu Xie ,  Kun-Lung Wu ,  Sheng-Chung Huang ,  San-Yong Yang ,  Xin-Ping Zhang ,  Jing Liu

IPC分类号： G05B11/28

CPC分类号： G01P3/48 ,  G01P3/486

摘要： A system is used to measure a fan rotational speed. The system includes a main controller, a first socket coupled to the linear fan, a second socket connected to the main controller, and an optical fiber amplifier connected to the main controller. A PWM (pulse width module) fan is coupled to the second socket, the PWM fan sends a first rotational speed signal, which represent a rotation speed of the PWM fan, to the main controller via the second socket. The optical fiber amplifier is capable of radiating light on fan blades of the linear fan, and sensing light reflected by the fan blades to count a rotational speed of the linear fan, and generating a second rotational speed signal which represents a rotational speed of the linear fan. The optical fiber amplifier sends the second rotational speed signal to the main controller.

摘要翻译： 系统用于测量风扇转速。 该系统包括主控制器，耦合到线性风扇的第一插座，连接到主控制器的第二插座和连接到主控制器的光纤放大器。 PWM（脉冲宽度模块）风扇耦合到第二个插座，PWM风扇通过第二个插座将一个表示PWM风扇的转速的第一转速信号发送到主控制器。 光纤放大器能够在线性风扇的风扇叶片上照射光，并且感测由风扇叶片反射的光以对线性风扇的转速进行计数，并产生代表线性风扇的转速的第二转速信号 风扇。 光纤放大器将第二转速信号发送到主控制器。

公开(公告)号：US20120059839A1

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

申请号：US12876348

申请日：2010-09-07

申请人： Henrique Andrade ,  Bugra Gedik ,  Martin J. Hirzel ,  Robert J. Soule ,  Huayong Wang ,  Kun-Lung Wu ,  Qiong Zou

发明人： Henrique Andrade ,  Bugra Gedik ,  Martin J. Hirzel ,  Robert J. Soule ,  Huayong Wang ,  Kun-Lung Wu ,  Qiong Zou

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

CPC分类号： G06F17/3056

摘要： An Open Database Connectivity (ODBC) proxy infrastructure to transparently route incoming queries to one or more selected query engines. The ODBC proxy receives a query from an application, and determines based on the characteristics of the query and the capabilities of the query engines which one or more query engines are to perform the query. The proxy then routes the query to the one or more query engines, which perform the query. The results are then returned to the proxy, which provides the results to the application.

摘要翻译： 开放数据库连接（ODBC）代理基础架构，用于将传入的查询透明地路由到一个或多个选定的查询引擎。 ODBC代理从应用程序接收查询，并根据查询的特征以及一个或多个查询引擎执行查询的查询引擎的功能进行确定。 然后，代理将查询路由到一个或多个执行查询的查询引擎。 然后将结果返回给代理，该代理将结果提供给应用程序。

公开(公告)号：US20120054173A1

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

申请号：US12868344

申请日：2010-08-25

申请人： Henrique Andrade ,  Bugra Gedik ,  Martin J. Hirzel ,  Robert Soule ,  Hua Yong Wang ,  Kun-Lung Wu ,  Qiong Zou

发明人： Henrique Andrade ,  Bugra Gedik ,  Martin J. Hirzel ,  Robert Soule ,  Hua Yong Wang ,  Kun-Lung Wu ,  Qiong Zou

IPC分类号： G06F17/30

CPC分类号： G06F17/30516

摘要： A method of transforming relational queries of a database into on a data processing system includes receiving a series of relational queries, transforming first parts of the queries into a continuous query embodied as a streaming application, sending parameters in second parts of the queries in the series to the streaming application as a data stream, and executing the continuous query based on the received data stream to generate query results for the series of relational queries. Each query in the series includes a first part and a second part. The first parts are a pattern common to all the queries in the series and the second parts each have one or more parameters that are not common to all of the queries in the series.

摘要翻译： 将数据库的关系查询变换到数据处理系统的方法包括：接收一系列关系查询，将查询的第一部分转换成体现为流应用的连续查询，在该系列的查询的第二部分中发送参数 作为数据流的流应用，并且基于接收到的数据流执行连续查询以生成用于一系列关系查询的查询结果。 该系列中的每个查询包括第一部分和第二部分。 第一部分是系列中所有查询共同的模式，第二部分每个都有一个或多个参数，这些参数对于该系列中的所有查询都不常见。

公开(公告)号：US08117331B2

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

申请号：US12165524

申请日：2008-06-30

申请人： Bugra Gedik ,  Kun-Lung Wu ,  Philip S. Yu

发明人： Bugra Gedik ,  Kun-Lung Wu ,  Philip S. Yu

IPC分类号： G06F15/16

CPC分类号： H04L49/90

摘要： One embodiment of the present method and apparatus adaptive load shedding includes receiving at least one data stream (comprising a plurality of tuples, or data items) into a first sliding window of memory. A subset of tuples from the received data stream is then selected for processing in accordance with at least one data stream operation, such as a data stream join operation. Tuples that are not selected for processing are ignored. The number of tuples selected and the specific tuples selected depend at least in part on a variety of dynamic parameters, including the rate at which the data stream (and any other processed data streams) is received, time delays associated with the received data stream, a direction of a join operation performed on the data stream and the values of the individual tuples with respect to an expected output.

摘要翻译： 本发明的方法和设备的一个实施例是自适应负载脱落包括将至少一个数据流（包括多个元组或数据项）接收到存储器的第一滑动窗口中。 然后根据至少一个数据流操作（例如数据流加入操作）选择来自接收到的数据流的元组的子集用于处理。 未选择处理的元组将被忽略。 所选择的元组的数量和所选择的特定元组至少部分取决于各种动态参数，包括接收数据流（和任何其他处理的数据流）的速率，与接收到的数据流相关联的时间延迟， 对数据流执行的连接操作的方向和相对于预期输出的单个元组的值。

公开(公告)号：US07940672B2

公开(公告)日：2011-05-10

申请号：US11540436

申请日：2006-09-29

申请人： Shyh-Kwei Chen ,  Michail Vlachos ,  Kun-Lung Wu ,  Philip Shi-lung Yu

发明人： Shyh-Kwei Chen ,  Michail Vlachos ,  Kun-Lung Wu ,  Philip Shi-lung Yu

IPC分类号： G01R31/08

CPC分类号： G06Q10/04 ,  G06Q40/00 ,  G06Q50/00 ,  H04L41/064 ,  H04L43/0894

摘要： Systems and methods for the identification of correlated burst events among two or more data streams, given one or more specific query time spans are disclosed. Also broadly contemplated is the act of finding, from one or more data streams, those streams that have correlated burst events with another given data stream within a time span.

摘要翻译： 公开了用于在给定一个或多个特定查询时间跨度的两个或多个数据流之间识别相关突发事件的系统和方法。 还广泛考虑的是从一个或多个数据流中发现在时间跨度内具有与另一个给定数据流相关联的突发事件的那些流的动作。