公开(公告)号：US09465846B2

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

申请号：US13111740

申请日：2011-05-19

Applicant: Qiming Chen ,  Meichun Hsu

Inventor： Qiming Chen ,  Meichun Hsu

IPC: G06F17/00 ,  G06F17/30

CPC classification number: G06F17/30516

Abstract: 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.

Abstract translation: 数据流存储在数据库中。 事件管道存储来自数据流的事件的滑动窗口。 通过利用存储在事件管道中的事件的滑动窗口来响应查询。

公开(公告)号：US09338061B2

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

申请号：US13457449

申请日：2012-04-26

Applicant: Qiming Chen ,  Meichun Hsu

Inventor： Qiming Chen ,  Meichun Hsu

IPC: G06F15/16 ,  H04L12/24

CPC classification number: H04L41/14

Abstract: 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.

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

公开(公告)号：US20140040237A1

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

申请号：US13563176

申请日：2012-07-31

Applicant: Qiming Chen ,  Meichun Hsu

Inventor： Qiming Chen ,  Meichun Hsu

IPC: G06F17/30

CPC classification number: G06F16/24568

Abstract: 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.

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

公开(公告)号：US20130282654A1

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

申请号：US13454693

申请日：2012-04-24

Applicant: Qiming Chen ,  Meichun Hsu

Inventor： Qiming Chen ,  Meichun Hsu

IPC: G06F17/30 ,  G06F15/16

CPC classification number: G06F9/54 ,  G06F16/25

Abstract: 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.

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

公开(公告)号：US20130238656A1

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

申请号：US13418055

申请日：2012-03-12

Applicant: Qiming Chen ,  Meichun Hsu

Inventor： Qiming Chen ,  Meichun Hsu

IPC: G06F17/30

CPC classification number: G06F17/30575

Abstract: 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.

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

公开(公告)号：US20130191413A1

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

申请号：US13878473

申请日：2010-10-14

Applicant: Qiming Chen ,  Meichun Hsu

Inventor： Qiming Chen ,  Meichun Hsu

IPC: G06F17/30

CPC classification number: G06F17/30424 ,  G06F17/30516

Abstract: 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.

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

公开(公告)号：US20130013360A1

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

申请号：US13615197

申请日：2012-09-13

Applicant: Qiming Chen ,  Meichun Hsu ,  Vinkesh Mehta

Inventor： Qiming Chen ,  Meichun Hsu ,  Vinkesh Mehta

IPC: G06Q10/06

CPC classification number: G06Q10/103 ,  G06Q10/06 ,  G06Q10/06311 ,  G06Q10/10 ,  H04L51/04 ,  Y02P90/86

Abstract: 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.

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

公开(公告)号：US20110047172A1

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

申请号：US12544227

申请日：2009-08-20

Applicant: Qiming Chen ,  Bin Zhang ,  Ren WU ,  Andy Therber ,  Meichun Hsu ,  Hans Zeller ,  David Birdsall

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

IPC: G06F17/30

CPC classification number: G06F17/30445

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

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

公开(公告)号：US07007020B1

公开(公告)日：2006-02-28

申请号：US09524140

申请日：2000-03-10

Applicant: Qiming Chen ,  Jie Deng ,  Umeshwar Dayal ,  Meichun Hsu

Inventor： Qiming Chen ,  Jie Deng ,  Umeshwar Dayal ,  Meichun Hsu

IPC: G06F17/30

CPC classification number: G06F17/30539 ,  G06F17/30592 ,  G06Q30/0201 ,  Y10S707/99936

Abstract: A distributed OLAP-based method and system for generating association rules. An architecture is provided for processing transaction data to generate summary information, customer profiles, and association rules. The distributed system includes at least two layers of data warehouse/OLAP stations: local data-warehouse OLAP stations (LDOSs) and a global data-warehouse OLAP station (GDOS). The LDOSs perform local data mining and summarization, and the GDOS merges, mines, and summarizes the input data received from LDOSs. The summarized data is then utilized by the GDOS to generate association rules that can be provided to the LDOSs for business planning.

Abstract translation: 一种基于分布式OLAP的方法和系统，用于生成关联规则。 提供了一种用于处理事务数据以生成摘要信息，客户简档和关联规则的架构。 分布式系统包括至少两层数据仓库/ OLAP站：本地数据仓库OLAP站（LDOS）和全球数据仓库OLAP站（GDOS）。 LDOS执行本地数据挖掘和总结，GDOS合并，挖掘和归纳从LDOS收到的输入数据。 然后，GDOS利用汇总数据生成可以提供给LDOS进行业务规划的关联规则。

公开(公告)号：US20050210456A1

公开(公告)日：2005-09-22

申请号：US11102999

申请日：2005-04-11

Applicant: Qiming Chen ,  Umeshwar Dayal ,  Meichun Hsu

Inventor： Qiming Chen ,  Umeshwar Dayal ,  Meichun Hsu

IPC: G06Q30/06 ,  G06F9/45

CPC classification number: G06Q30/06

Abstract: An agent computer program for use in an automated electronic commerce infrastructure. A client-agent communication mechanism for enabling communication between an agent computer program and at least one client computer process is provided. The client-agent communication mechanism includes a web server embedded in the agent computer program that utilizes a predetermined Internet communication protocol for communication between the agent computer program and the client computer process. An inter-agent communication mechanism is provided for enabling the agent computer program to communicate with other agents. The inter-agent communication mechanism employs documents written in a predetermined markup language for communication.

Abstract translation: 一种用于自动电子商务基础设施的代理计算机程序。 提供了一种用于实现代理计算机程序与至少一个客户端计算机进程之间的通信的客户端代理通信机制。 客户端代理通信机制包括嵌入到代理计算机程序中的web服务器，该Web服务器利用预定的因特网通信协议来代理代理计算机程序和客户端计算机进程之间的通信。 提供代理间通信机制，用于使代理计算机程序能够与其他代理进行通信。 代理间通信机制采用以预定的标记语言编写的用于通信的文档。