APPARATUS AND METHOD FOR MANAGING DATA STREAM DISTRIBUTED PARALLEL PROCESSING SERVICE
    1.
    发明申请
    APPARATUS AND METHOD FOR MANAGING DATA STREAM DISTRIBUTED PARALLEL PROCESSING SERVICE 有权
    用于管理数据流分布式并行处理服务的装置和方法

    公开(公告)号:US20130219405A1

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

    申请号:US13585252

    申请日:2012-08-14

    CPC classification number: G06F9/5038 G06F9/505

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

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

    SYSTEM AND METHOD FOR PROCESSING CONTINUOUS INTEGRATED QUERIES ON BOTH DATA STREAM AND STORED DATA USING USER-DEFINED SHARE TRIGGER
    2.
    发明申请
    SYSTEM AND METHOD FOR PROCESSING CONTINUOUS INTEGRATED QUERIES ON BOTH DATA STREAM AND STORED DATA USING USER-DEFINED SHARE TRIGGER 失效
    使用用户定义的分享触发器处理两个数据流和存储数据的连续集成查询的系统和方法

    公开(公告)号:US20080046401A1

    公开(公告)日:2008-02-21

    申请号:US11838599

    申请日:2007-08-14

    CPC classification number: G06F17/30516

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

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

    Apparatus and method for managing data stream distributed parallel processing service
    3.
    发明授权
    Apparatus and method for managing data stream distributed parallel processing service 有权
    用于管理数据流分布式并行处理服务的装置和方法

    公开(公告)号:US08997109B2

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

    申请号:US13585252

    申请日:2012-08-14

    CPC classification number: G06F9/5038 G06F9/505

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

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

    INCREMENTAL MAPREDUCE-BASED DISTRIBUTED PARALLEL PROCESSING SYSTEM AND METHOD FOR PROCESSING STREAM DATA
    4.
    发明申请
    INCREMENTAL MAPREDUCE-BASED DISTRIBUTED PARALLEL PROCESSING SYSTEM AND METHOD FOR PROCESSING STREAM DATA 审中-公开
    基于MAPREDUCE的分布式并行处理系统和处理流数据的方法

    公开(公告)号:US20110154339A1

    公开(公告)日:2011-06-23

    申请号:US12968647

    申请日:2010-12-15

    CPC classification number: G06F9/5027 G06F15/17393 G06F2209/5017

    Abstract: Disclosed herein is a system for processing large-capacity data in a distributed parallel processing manner based on MapReduce using a plurality of computing nodes. The distributed parallel processing system is configured to provide an incremental MapReduce-based distributed parallel processing function for large-capacity stream data which is being continuously collected even during the performance of the distributed parallel processing, as well as for large-capacity stored data which has been previously collected.

    Abstract translation: 本文公开了一种基于使用多个计算节点的MapReduce以分布式并行处理方式处理大容量数据的系统。 分布式并行处理系统被配置为为大容量流数据提供增量的基于MapReduce的分布式并行处理功能,即使在分布式并行处理的执行期间也连续收集,并且对于大容量存储的数据 以前收集。

    System and method for processing integrated queries against input data stream and data stored in database using trigger
    5.
    发明申请
    System and method for processing integrated queries against input data stream and data stored in database using trigger 审中-公开
    使用触发器对输入数据流和存储在数据库中的数据进行集成查询的系统和方法

    公开(公告)号:US20070136254A1

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

    申请号:US11594641

    申请日:2006-11-08

    CPC classification number: G06F16/24568 G06F16/80

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

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

    SERVICE PROVIDING METHOD AND DEVICE USING THE SAME
    6.
    发明申请
    SERVICE PROVIDING METHOD AND DEVICE USING THE SAME 审中-公开
    服务提供方法和使用该设备的设备

    公开(公告)号:US20120158816A1

    公开(公告)日:2012-06-21

    申请号:US13325301

    申请日:2011-12-14

    CPC classification number: G06F9/4881

    Abstract: Disclosed are service providing method and device, including: collecting execution state information about a plurality of tasks that constitute at least one service, and are dynamically distributed and arranged over a plurality of nodes; and performing scheduling based on the collected execution state information about the plurality of tasks, wherein each of the plurality of tasks has at least one input source and output source, and a unit of data to be processed for each input source and a data processing operation are defined by a user, and the scheduling is to delete at least a portion of data input into at least one task or to process the at least a portion of input data in at least one duplicate task by referring to the defined unit of data. In particular, the present invention may effectively provide a service of analyzing and processing large stream data in semi-real time.

    Abstract translation: 公开的是服务提供方法和装置,包括:收集关于构成至少一个服务的多个任务的执行状态信息,并且动态地分布和布置在多个节点上; 以及基于所收集的关于所述多个任务的执行状态信息执行调度,其中所述多个任务中的每一个具有至少一个输入源和输出源以及要针对每个输入源处理的数据单元和数据处理操作 由用户定义,并且调度是将输入到至少一个任务中的数据的至少一部分删除,或者通过参考所定义的数据单元来处理至少一个重复任务中的至少一部分输入数据。 特别地,本发明可以有效地提供半实时分析和处理大流数据的服务。

    Apparatus and method for producing 3D sound
    7.
    发明授权
    Apparatus and method for producing 3D sound 有权
    用于产生3D声音的装置和方法

    公开(公告)号:US07599498B2

    公开(公告)日:2009-10-06

    申请号:US11175326

    申请日:2005-07-07

    CPC classification number: H04S5/02 H04R2499/11 H04S5/00

    Abstract: Disclosed herein is an apparatus for producing 3D sound. The apparatus includes a determination unit, a mono sound spreading unit, a stereo sound spreading unit, a selection unit, and a 3D sound accelerator. The determination unit receives a source sound file and determines whether the source sound file is mono or stereo. The mono sound spreading unit converts the source sound into pseudo-stereo sound and performs sound spreading on the pseudo-stereo sound, if the source sound is determined to be mono. The stereo sound spreading unit performs sound spreading on the source sound, if the source sound is determined to be stereo. The selection unit receives the output of the mono sound spreading unit or stereo sound spreading unit, and transfers the output to headphones if the headphone reproduction has been selected. The 3D sound accelerator receives the output from the selection unit if speaker reproduction has been selected, removes crosstalk from the output, and transfers the crosstalk-free output to speakers.

    Abstract translation: 本文公开了一种用于产生3D声音的装置。 该装置包括确定单元,单声道扩散单元,立体声扩声单元,选择单元和3D声音加速器。 确定单元接收源声音文件并确定源声音文件是单声道还是立体声。 如果源声音被确定为单声道,则单声道扩散单元将源声音转换为伪立体声,并对伪立体声进行声音扩展。 如果源声音被确定为立体声,则立体声扩散单元对源声音进行声音扩展。 选择单元接收单声道扩声单元或立体声声音扩展单元的输出,并且如果已经选择了耳机再现,则将输出传送到耳机。 如果选择了扬声器再现,则3D声音加速器从选择单元接收输出,从输出中消除串扰,并将无串扰输出传送给扬声器。

    System and method for processing continuous integrated queries on both data stream and stored data using user-defined shared trigger
    9.
    发明授权
    System and method for processing continuous integrated queries on both data stream and stored data using user-defined shared trigger 失效
    用于使用用户定义的共享触发来处理数据流和存储数据的连续集成查询的系统和方法

    公开(公告)号:US07860884B2

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

    申请号:US11838599

    申请日:2007-08-14

    CPC classification number: G06F17/30516

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

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

    3D SOUND REPRODUCTION APPARATUS USING VIRTUAL SPEAKER TECHNIQUE IN PLURAL CHANNEL SPEAKER ENVIRONMENT
    10.
    发明申请
    3D SOUND REPRODUCTION APPARATUS USING VIRTUAL SPEAKER TECHNIQUE IN PLURAL CHANNEL SPEAKER ENVIRONMENT 审中-公开
    使用虚拟扬声器技术在三维声道扬声器环境中使用的3D声音再现设备

    公开(公告)号:US20090103737A1

    公开(公告)日:2009-04-23

    申请号:US12110002

    申请日:2008-04-25

    CPC classification number: H04S3/00

    Abstract: Disclosed herein is an apparatus for providing 3D sound through plural-channel speakers. The apparatus includes a stereo channel virtual speaker generation device for performing spreading of low-pitch ranges and high-pitch ranges on input left and right channel signals, performing spreading of sound images and preservation of front sound images using the high-pitch range-spread signals, and outputting the sums of left and right processing results; a multi channel virtual speaker generation device for performing spreading of low-pitch ranges and high-pitch ranges on input left front channel, right front channel, left surround channel and right surround channel signals, performing spreading of sound images using the high-pitch range-spread signals, performing preservation of front sound images using front center channel and LFE channel signals, adjusting the gains of the processing results, and outputting the sums of left and right processing results, and an output device for outputting the signals to the plural-channel speakers.

    Abstract translation: 本文公开了一种用于通过多声道扬声器提供3D声音的装置。 该装置包括立体声通道虚拟扬声器产生装置,用于在输入的左右声道信号上执行低音调范围和高音调范围的扩展,使用高音调范围扩展来执行声音图像的扩展和保存前部声像 信号,并输出左右处理结果的和; 多声道虚拟扬声器产生装置,用于在输入的左前通道,右前通道,左环绕声道和右环绕声道信号上执行低音调范围和高音调范围的扩展,使用高音高范围进行声像的扩展 扩展信号,使用前中心声道和LFE声道信号执行前声像的保存,调整处理结果的增益,以及输出左和右处理结果的和,以及输出装置, 频道扬声器

Patent Agency Ranking