公开(公告)号：US07860884B2

公开(公告)日：2010-12-28

申请号：US11838599

申请日：2007-08-14

申请人： Myung-Cheol Lee ,  Hyun-Hwa Choi ,  Mi-Young Lee ,  Myung-Joon Kim

发明人： Myung-Cheol Lee ,  Hyun-Hwa Choi ,  Mi-Young Lee ,  Myung-Joon Kim

IPC分类号： G06F7/00

CPC分类号： G06F17/30516

摘要： Provided are a system and method for processing continuous integrated queries on both data stream and stored data using user-defined shared trigger. The system includes a data stream manager for managing data stream inputted from outside; a continuous integrated queries manager for managing the continuous integrated queries inputted from an external application; a trigger manager for managing the user-defined shared trigger inputted from the external application and registering the user-defined shared trigger in an external database; a trigger result manager for forming and managing a trigger result set from a performance result of the user-defined shared trigger registered in the cooperation database; and a continuous integrated queries performer for processing the continuous integrated queries referring to the transmitted data stream and trigger result set.

摘要翻译： 提供了一种用于使用用户定义的共享触发来处理数据流和存储数据的连续集成查询的系统和方法。 该系统包括用于管理从外部输入的数据流的数据流管理器; 用于管理从外部应用输入的连续集成查询的连续集成查询管理器; 用于管理从外部应用输入的用户定义的共享触发并将用户定义的共享触发记录在外部数据库中的触发管理器; 触发结果管理器，用于从登记在协作数据库中的用户定义的共享触发的执行结果形成和管理触发结果集; 以及连续的综合查询执行器，用于处理连续的综合查询，参考发送的数据流和触发结果集。

公开(公告)号：US20070136254A1

公开(公告)日：2007-06-14

申请号：US11594641

申请日：2006-11-08

申请人： Hyun-Hwa Choi ,  Mi-Young Lee ,  Myung-Cheol Lee ,  Myung-Joon Kim

发明人： Hyun-Hwa Choi ,  Mi-Young Lee ,  Myung-Cheol Lee ,  Myung-Joon Kim

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

CPC分类号： G06F16/24568 ,  G06F16/80

摘要： Provided are a system and a method for processing integrated queries against an input data stream and data stored in a database using trigger. The system for processing an integrated query against an input data stream and data stored in a database using a trigger, including: a data stream manager for managing a continuously inputted data stream; a trigger result manager for registering a trigger in a database which interworks with the trigger result manager and forming a set of results that are obtained by executing the registered trigger to thereby provide the set of results in real time; and an executer for processing an integrated query against the data stream from the data stream manager and data stored in the database, wherein the integrated query is processed by referring to the set of results from the trigger result manager for the data stored in the database.

摘要翻译： 提供了一种用于使用触发器来处理针对输入数据流的集成查询和存储在数据库中的数据的系统和方法。 用于使用触发来处理针对输入数据流的综合查询和存储在数据库中的数据的系统，包括：用于管理连续输入的数据流的数据流管理器; 触发结果管理器，用于在与触发结果管理器进行交互的数据库中注册触发器，并形成通过执行注册的触发而获得的一组结果，从而实时提供该组结果; 以及执行器，用于处理来自数据流管理器的数据流的综合查询和存储在数据库中的数据，其中通过参考存储在数据库中的数据的触发结果管理器的结果集来处理集成查询。

公开(公告)号：US20130219405A1

公开(公告)日：2013-08-22

申请号：US13585252

申请日：2012-08-14

申请人： Myung-Cheol LEE ,  Hyun-Hwa Choi ,  Hun-Soon Lee ,  Byoung-Seob KIM ,  Mi-Young Lee

发明人： Myung-Cheol LEE ,  Hyun-Hwa Choi ,  Hun-Soon Lee ,  Byoung-Seob KIM ,  Mi-Young Lee

IPC分类号： G06F9/46

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

摘要： Disclosed herein are an apparatus and method for managing a data stream distributed parallel processing service. The apparatus includes a service management unit, a Quality of Service (QoS) monitoring unit, and a scheduling unit. The service management unit registers a plurality of tasks constituting the data stream distributed parallel processing service. The QoS monitoring unit gathers information about the load of the plurality of tasks and information about the load of a plurality of nodes constituting a cluster which provides the data stream distributed parallel processing service. The scheduling unit arranges the plurality of tasks by distributing the plurality of tasks among the plurality of nodes based on the information about the load of the plurality of tasks and the information about the load of the plurality of nodes.

摘要翻译： 这里公开了一种用于管理分布式并行处理服务的数据流的装置和方法。 该装置包括服务管理单元，服务质量（QoS）监视单元和调度单元。 服务管理单元登记构成数据流分散并行处理服务的多个任务。 QoS监视单元收集关于多个任务的负载的信息和关于构成提供数据流分布式并行处理服务的集群的多个节点的负载的信息。 调度单元基于关于多个任务的负载的信息和关于多个节点的负载的信息，在多个节点之间分配多个任务来配置多个任务。

公开(公告)号：US08997109B2

公开(公告)日：2015-03-31

申请号：US13585252

申请日：2012-08-14

申请人： Myung-Cheol Lee ,  Hyun-Hwa Choi ,  Hun-Soon Lee ,  Byoung-Seob Kim ,  Mi-Young Lee

发明人： Myung-Cheol Lee ,  Hyun-Hwa Choi ,  Hun-Soon Lee ,  Byoung-Seob Kim ,  Mi-Young Lee

IPC分类号： G06F9/46 ,  G06F9/50

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

摘要： Disclosed herein are an apparatus and method for managing a data stream distributed parallel processing service. The apparatus includes a service management unit, a Quality of Service (QoS) monitoring unit, and a scheduling unit. The service management unit registers a plurality of tasks constituting the data stream distributed parallel processing service. The QoS monitoring unit gathers information about the load of the plurality of tasks and information about the load of a plurality of nodes constituting a cluster which provides the data stream distributed parallel processing service. The scheduling unit arranges the plurality of tasks by distributing the plurality of tasks among the plurality of nodes based on the information about the load of the plurality of tasks and the information about the load of the plurality of nodes.

摘要翻译： 这里公开了一种用于管理分布式并行处理服务的数据流的装置和方法。 该装置包括服务管理单元，服务质量（QoS）监视单元和调度单元。 服务管理单元登记构成数据流分散并行处理服务的多个任务。 QoS监视单元收集关于多个任务的负载的信息和关于构成提供数据流分布式并行处理服务的集群的多个节点的负载的信息。 调度单元基于关于多个任务的负载的信息和关于多个节点的负载的信息，在多个节点之间分配多个任务来配置多个任务。