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