公开(公告)号：US20130080413A1

公开(公告)日：2013-03-28

申请号：US13246947

申请日：2011-09-28

申请人： Qiming Chen ,  Meichun Hsu

发明人： Qiming Chen ,  Meichun Hsu

IPC分类号： G06F17/30

CPC分类号： G06F17/30516 ,  G06F17/30584

摘要： Multi-stream analytics is disclosed. An example method of multi-stream analytics with a query engine includes punctuating unbounded streaming data into data chunks, each of the data chunks representing a bounded data set in the unbounded streaming data. The method also includes processing one of the data chunks. The method also includes rewinding a query instance for processing another of the data chunks.

摘要翻译： 披露了多流分析。 使用查询引擎的多流分析的示例性方法包括将无界流数据标点到数据块中，每个数据块表示无界流数据中的有界数据集。 该方法还包括处理其中一个数据块。 该方法还包括倒回用于处理另一数据块的查询实例。

公开(公告)号：US08400458B2

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

申请号：US12556401

申请日：2009-09-09

申请人： Ren Wu ,  Bin Zhang ,  Meichun Hsu

发明人： Ren Wu ,  Bin Zhang ,  Meichun Hsu

IPC分类号： G06F15/80

CPC分类号： G06F15/8023 ,  G06T1/00

摘要： A method is provided for optimizing computer processes executing on a graphics processing unit (GPU) and a central processing unit (CPU). Process data is subdivided into sequentially processed data and parallel processed data. The parallel processed data is subdivided into a plurality of data blocks assigned to a plurality of processing cores of the GPU. The data blocks on the GPU are processed with other data blocks in parallel on the plurality of processing cores. Sequentially processed data is processed on the CPU. Result data processed on the CPU is returned.

摘要翻译： 提供了一种用于优化在图形处理单元（GPU）和中央处理单元（CPU）上执行的计算机处理的方法。 过程数据被细分为顺序处理的数据和并行处理的数据。 并行处理的数据被细分为分配给GPU的多个处理核心的多个数据块。 GPU上的数据块在多个处理核上并行处理与其他数据块。 在CPU上处理顺序处理的数据。 返回CPU处理的结果数据。

公开(公告)号：US20120317049A1

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

申请号：US13155570

申请日：2011-06-08

申请人： Ming C. Hao ,  Umeshwar Dayal ,  Christian Rohrdantz ,  Meichun Hsu ,  Mohamed E. Dekhil ,  Riddhiman Ghosh

发明人： Ming C. Hao ,  Umeshwar Dayal ,  Christian Rohrdantz ,  Meichun Hsu ,  Mohamed E. Dekhil ,  Riddhiman Ghosh

IPC分类号： G06Q10/00

CPC分类号： G06Q10/00

摘要： Data records containing user feedback regarding at least one offering are received. From among candidate attributes in the received data records, a subset of attributes that relate to user sentiment regarding the at least one offering is selected, where the selecting is according to selection criteria including frequency of occurrence of the candidate attributes, relative amounts of negative and positive feedback associated with the candidate attributes, and time density of feedback associated with the candidate attributes. A visualization of at least one sentiment characteristic of the selected subset of attributes that relate to user sentiment is presented for display.

摘要翻译： 收到包含至少一个产品的用户反馈的数据记录。 从所接收的数据记录中的候选属性中，选择与关于至少一个产品的用户情绪相关的属性子集，其中选择是根据选择标准，包括候选属性的出现频率，负的相对量和 与候选属性相关联的正反馈以及与候选属性相关联的反馈的时间密度。 呈现与用户情绪相关的所选择的属性子集的至少一个情绪特征的可视化显示。

公开(公告)号：US20120296861A1

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

申请号：US13111740

申请日：2011-05-19

申请人： Qiming Chen ,  Meichun Hsu

发明人： Qiming Chen ,  Meichun Hsu

IPC分类号： G06F17/30

CPC分类号： G06F17/30516

摘要： A data stream is stored in a database. An event pipe stores a sliding window of events from the data stream. A query is responded to by utilizing the sliding window of events stored in the event pipe.

摘要翻译： 数据流存储在数据库中。 事件管道存储来自数据流的事件的滑动窗口。 通过利用存储在事件管道中的事件的滑动窗口来响应查询。

公开(公告)号：US08260826B2

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

申请号：US12907940

申请日：2010-10-19

申请人： Qiming Chen ,  Meichun Hsu

发明人： Qiming Chen ,  Meichun Hsu

IPC分类号： G06F17/30

CPC分类号： G06F17/30516

摘要： A system and method for processing data are described. The method quantizes a portion of data processed at a first node within a distributed database processing system to generate one or more quantization tuples, aggregates the tuples at the node to create a plurality of aggregated tuples, and transmits the aggregated tuples to a second node within the distributed database processing system.

摘要翻译： 描述用于处理数据的系统和方法。 该方法量化在分布式数据库处理系统内的第一节点处理的数据的一部分以生成一个或多个量化元组，聚集节点处的元组以创建多个聚合元组，并将聚合的元组发送到第 分布式数据库处理系统。

公开(公告)号：US08260803B2

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

申请号：US12907948

申请日：2010-10-19

申请人： Meichun Hsu ,  Qiming Chen

发明人： Meichun Hsu ,  Qiming Chen

IPC分类号： G06F17/30

CPC分类号： G06F17/30516 ,  G06F17/30445

摘要： A method and system for processing a data stream are described. The method executes, until the occurrence of a cut condition, a map function from a set of query processing steps to generate map results for a first portion of the data stream, executes a reduce function from the set of query processing steps to generate history-sensitive data from the map results, and rewinds the set of query processing steps, without termination of processing. The history-sensitive data is maintained for a second execution of the map function and reduce function on a second portion of the data stream.

摘要翻译： 描述用于处理数据流的方法和系统。 该方法执行直到发生切割条件，来自一组查询处理步骤的地图函数以生成数据流的第一部分的地图结果，从该组查询处理步骤执行缩减函数，以生成历史记录 - 来自地图的敏感数据结果，并且倒带一组查询处理步骤，而不终止处理。 维护历史敏感数据以进行地图功能的第二次执行并减少数据流的第二部分上的功能。

公开(公告)号：US20120185460A1

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

申请号：US13007487

申请日：2011-01-14

申请人： Qiming Chen ,  Meichun Hsu

发明人： Qiming Chen ,  Meichun Hsu

IPC分类号： G06F17/30

CPC分类号： G06F9/4421 ,  G06F9/448 ,  G06F17/30477 ,  G06F17/30516 ,  G06F17/30545 ,  G06F17/30595 ,  G06F17/30926

摘要： Systems and methods of block computation are disclosed. An example of a method includes buffering a plurality of tuples in a build phase. The method also includes, after buffering a last of the plurality of tuples, applying a computation to all of the buffered tuples in a compute phase. The method also includes returning results of the computation one tuple at a time to a query processing pipeline in a stream-out phase.

摘要翻译： 公开了块计算的系统和方法。 一种方法的示例包括在构建阶段缓冲多个元组。 该方法还包括在缓冲多个元组中的最后一个元组之后，在计算阶段对所有被缓存的元组应用计算。 该方法还包括在流出阶段中将一个元组的计算结果一次返回到查询处理流水线。

公开(公告)号：US20120078975A1

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

申请号：US12907940

申请日：2010-10-19

申请人： Qiming CHEN ,  Meichun Hsu

发明人： Qiming CHEN ,  Meichun Hsu

IPC分类号： G06F17/30

CPC分类号： G06F17/30516

摘要： A system and method for processing data are described. The method quantizes a portion of data processed at a first node within a distributed database processing system to generate one or more quantization tuples, aggregates the tuples at the node to create a plurality of aggregated tuples, and transmits the aggregated tuples to a second node within the distributed database processing system.

摘要翻译： 描述用于处理数据的系统和方法。 该方法量化在分布式数据库处理系统内的第一节点处理的数据的一部分以生成一个或多个量化元组，聚集节点处的元组以创建多个聚合元组，并将聚合的元组发送到第 分布式数据库处理系统。

公开(公告)号：US08112408B2

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

申请号：US12510933

申请日：2009-07-28

申请人： Qiming Chen ,  Meichun Hsu ,  Rui Llu

发明人： Qiming Chen ,  Meichun Hsu ,  Rui Llu

IPC分类号： G06F17/30

CPC分类号： B60Q9/00 ,  G01D3/08 ,  G01D11/28 ,  G06F9/4484

摘要： A method is provided for generating a user-defined function (UDF) on a database engine of a database server. A user-function is sent to the database engine. The user-function includes a relational declaration with application and query logic. When the database engine receives the user-function, the database engine generates a function shell. The UDF processes the relational declaration of the user-defined function. The UDF includes the user-function and the function shell. The function shell returns a final data result of the user-defined function through the shell from the database engine.

摘要翻译： 提供了一种用于在数据库服务器的数据库引擎上生成用户定义的功能（UDF）的方法。 用户功能被发送到数据库引擎。 用户函数包括具有应用和查询逻辑的关系声明。 当数据库引擎收到用户函数时，数据库引擎会生成一个函数shell。 UDF处理用户定义函数的关系声明。 UDF包括用户功能和功能shell。 函数shell通过shell从数据库引擎返回用户定义函数的最终数据结果。

公开(公告)号：US08046373B2

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

申请号：US12359324

申请日：2009-01-25

申请人： Qiming Chen ,  Meichun Hsu

发明人： Qiming Chen ,  Meichun Hsu

IPC分类号： G06F17/30

CPC分类号： G06F17/30445

摘要： Methods, systems, and computer program products are provided for performing structured parallel data intensive computations. A SQL-FCF framework that defines a SQL construct based interface for performing the computations is provided. The computations within an application are coded as table valued functions (TVFs). Data for the application is partitioned into data partitions to co-locate and load balance the data partitions and corresponding computations. The TVFs are invoked and applied to corresponding ones of the data partitions in a structured order defined by function control forms (FCF).

摘要翻译： 提供了方法，系统和计算机程序产品，用于执行结构化并行数据密集型计算。 提供了一个定义用于执行计算的基于SQL构造的接口的SQL-FCF框架。 应用程序中的计算被编码为表值函数（TVFs）。 将应用程序的数据划分为数据分区，以共同定位和负载平衡数据分区和相应的计算。 TVF被调用并以由功能控制表（FCF）定义的结构化顺序应用于相应的数据分区。