公开(公告)号：US10346375B2

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

申请号：US13457444

申请日：2012-04-26

申请人： Qiming Chen ,  Meichun Hsu ,  Jerry Z. Shan

发明人： Qiming Chen ,  Meichun Hsu ,  Jerry Z. Shan

IPC分类号： G06F16/00 ,  G06F16/21 ,  G06F16/22

摘要： In-database parallel analytics is disclosed. An example method includes receiving a function in a functional programming environment. The example method includes pushing operations for the function to a database layer for executing the operations. The example method also includes returning results of the operations to the functional programming environment.

公开(公告)号：US20130290300A1

公开(公告)日：2013-10-31

申请号：US13457444

申请日：2012-04-26

申请人： Qiming Chen ,  Meichun Hsu ,  Jerry Z. Shan

发明人： Qiming Chen ,  Meichun Hsu ,  Jerry Z. Shan

IPC分类号： G06F17/30

CPC分类号： G06F16/217 ,  G06F16/221

摘要： In-database parallel analytics is disclosed. An example method includes receiving a function in a functional programming environment. The example method includes pushing operations for the function to a database layer for executing the operations. The example method also includes returning results of the operations to the functional programming environment.

摘要翻译： 披露了数据库内并行分析。 示例性方法包括在功能编程环境中接收功能。 该示例方法包括将该功能的操作推送到用于执行操作的数据库层。 示例方法还包括将操作的结果返回到功能编程环境。

公开(公告)号：US09465846B2

公开(公告)日：2016-10-11

申请号：US13111740

申请日：2011-05-19

申请人： Qiming Chen ,  Meichun Hsu

发明人： Qiming Chen ,  Meichun Hsu

IPC分类号： G06F17/00 ,  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.

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

公开(公告)号：US09338061B2

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

申请号：US13457449

申请日：2012-04-26

申请人： Qiming Chen ,  Meichun Hsu

发明人： Qiming Chen ,  Meichun Hsu

IPC分类号： G06F15/16 ,  H04L12/24

CPC分类号： H04L41/14

摘要： An open station as a stream analysis operator container is disclosed. In an example, a method is stored as instructions on computer readable media and executable by a processor. The method includes packaging graph-structured stream transformations into a topology of a top-level dataflow process including stream transformation operators (STOs) on open stations. The method also includes sending a tuple from one of the STOs to every other STO in the topology subscribed to a data stream of the tuple.

摘要翻译： 公开了作为流分析操作者容器的开放站。 在一个示例中，方法作为指令存储在计算机可读介质上并且可由处理器执行。 该方法包括将图形结构化流转换包括在顶层数据流过程的拓扑中，包括开放站上的流转换算子（STO）。 该方法还包括将一个元组从一个STO发送到订阅该元组的数据流的拓扑中的每个其他STO。

公开(公告)号：US20140040237A1

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

申请号：US13563176

申请日：2012-07-31

申请人： Qiming Chen ,  Meichun Hsu

发明人： Qiming Chen ,  Meichun Hsu

IPC分类号： G06F17/30

CPC分类号： G06F16/24568

摘要： Managing retrieval of data from a data streaming process, such that a query required by multiple operator instances is not executed more than once. A Data Access Station (DAS) facilitates data retrieval for an operator(s) O and its multiple operator instances, and mitigates (or avoids) repetition of queries by the multiple operator instances.

摘要翻译： 管理数据流处理中的数据检索，使得多个操作符实例所需的查询不会多次执行。 数据访问站（DAS）便于操作员O及其多个操作员实例的数据检索，并减轻（或避免）多个操作者实例的查询重复。

公开(公告)号：US20130282654A1

公开(公告)日：2013-10-24

申请号：US13454693

申请日：2012-04-24

申请人： Qiming Chen ,  Meichun Hsu

发明人： Qiming Chen ,  Meichun Hsu

IPC分类号： G06F17/30 ,  G06F15/16

CPC分类号： G06F9/54 ,  G06F16/25

摘要： There is provided a computer-implemented method of performing inter-query engine communication. The method includes receiving a message from a first query engine agent over a signal communication network. The first query engine agent is associated with a first query engine. The method also includes determining, by a second query engine agent associated with a second query engine, a data exchange to perform based on the message. Additionally, the method includes performing the data exchange over a data communication network.

摘要翻译： 提供了执行查询间引擎通信的计算机实现的方法。 该方法包括通过信号通信网络从第一查询引擎代理接收消息。 第一个查询引擎代理与第一个查询引擎相关联。 该方法还包括通过与第二查询引擎相关联的第二查询引擎代理确定要基于该消息执行的数据交换。 另外，该方法包括通过数据通信网络执行数据交换。

公开(公告)号：US20130238656A1

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

申请号：US13418055

申请日：2012-03-12

申请人： Qiming Chen ,  Meichun Hsu

发明人： Qiming Chen ,  Meichun Hsu

IPC分类号： G06F17/30

CPC分类号： G06F17/30575

摘要： Page feed for efficient dataflow between distributed query engines is disclosed. An example method comprises storing a query result relation by a producer query as pages in a query engine buffer pool, and then sending these pages to a distributed caching platform (DCP) as the data source of another query. The example method also includes reading the result relation by a consumer query from the page stored in the DCP.

摘要翻译： 公开了分布式查询引擎之间的有效数据流的页面馈送。 示例性方法包括将生成器查询的查询结果关系存储为查询引擎缓冲池中的页面，然后将这些页面作为另一查询的数据源发送到分布式缓存平台（DCP）。 示例方法还包括从存储在DCP中的页面读取消费者查询的结果关系。

公开(公告)号：US20130191413A1

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

申请号：US13878473

申请日：2010-10-14

申请人： Qiming Chen ,  Meichun Hsu

发明人： Qiming Chen ,  Meichun Hsu

IPC分类号： G06F17/30

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

摘要： In continuous querying of a data stream, a query including query cycles can be initialized (310) on a query engine to analyze the data stream for desired information. The data stream can be processed (320) as segments, where a size of the segments is based on a user-defined parameter. The query cycles can be synchronized (330) with the segments of the data stream. A first segment can be analyzed (340) by performing the query on the first segment to obtain a first result. A query state of the query can be persisted (350) and the query operation can be rewound to begin a new query cycle. A second segment can be analyzed (360) in the new query cycle by performing the query on the second segment based on the first result.

摘要翻译： 在数据流的连续查询中，可以在查询引擎上初始化包括查询循环的查询（310），以分析所需信息的数据流。 可以将数据流处理（320）作为段，其中段的大小基于用户定义的参数。 查询周期可以与数据流的段同步（330）。 可以通过对第一段执行查询来获得第一结果来分析第一段（340）。 查询的查询状态可以被持久化（350），并且查询操作可以被倒退以开始一个新的查询周期。 可以在新的查询周期中通过基于第一个结果对第二个分段执行查询来分析（360）第二分段。

公开(公告)号：US20130013360A1

公开(公告)日：2013-01-10

申请号：US13615197

申请日：2012-09-13

申请人： Qiming Chen ,  Meichun Hsu ,  Vinkesh Mehta

发明人： Qiming Chen ,  Meichun Hsu ,  Vinkesh Mehta

IPC分类号： G06Q10/06

CPC分类号： G06Q10/103 ,  G06Q10/06 ,  G06Q10/06311 ,  G06Q10/10 ,  H04L51/04 ,  Y02P90/86

摘要： The present invention relates to devices and methods that coordinate an external conversation process between entities with an internal workflow of one of the entities. More particularly, it relates to devices and methods that are compliant with an inter-enterprise conversation process standard for routing electronic commerce documents between enterprises. Particular aspects of the present invention are described in the claims, specification and drawings.

摘要翻译： 本发明涉及利用其中一个实体的内部工作流来协调实体之间的外部会话处理的设备和方法。 更具体地说，本发明涉及符合企业间企业对话电子商务文档的跨企业对话处理标准的装置和方法。 在权利要求书，说明书和附图中描述了本发明的特定方面。

公开(公告)号：US20110047172A1

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

申请号：US12544227

申请日：2009-08-20

申请人： Qiming Chen ,  Bin Zhang ,  Ren WU ,  Andy Therber ,  Meichun Hsu ,  Hans Zeller ,  David Birdsall

发明人： Qiming Chen ,  Bin Zhang ,  Ren WU ,  Andy Therber ,  Meichun Hsu ,  Hans Zeller ,  David Birdsall

IPC分类号： G06F17/30

CPC分类号： G06F17/30445

摘要： One embodiment is a method that uses MapReduce and Relation Valued Functions (RVFs) with parallel processing to search a database and obtain search results.

摘要翻译： 一个实施例是使用具有并行处理的MapReduce和关系值函数（RVF）来搜索数据库并获得搜索结果的方法。