Patent application number | Description | Published |
20080255847 | Meeting visualization system - Voice of plural participants during a meeting is obtained and dialogue situations of the participants that change every second are displayed in real time, so that it is possible to provide a meeting visualization system for triggering more positive discussions. Voice data collected from plural voice collecting units associated with plural participants is processed by a voice processing server to extract speech information. The speech information is sequentially input to an aggregation server. A query process is performed for the speech information by a stream data processing unit of the aggregation server, so that activity data such as the accumulation value of speeches of the participants in the meeting is generated. A display processing unit visualizes and displays dialogue situations of the participants by using the sizes of circles and the thicknesses of lines on the basis of the activity data. | 10-16-2008 |
20090006310 | STREAM DATA PROCESSING METHOD AND STREAM DATA PROCESSING SYSTEM - In order to make real time and the avoidance of risk compatible according to the contents of processing by an application, an index ID applying module applies an index computed utilizing streams before and after stream data to the stream data, computes the index again according to a stream that varies every moment, applies an index computed based upon the index of the stream data to the result of the processing of the stream data according to a predetermined procedure and outputs it. An application that receives the result of the processing and the index of the result of the processing switches processing depending upon the index. | 01-01-2009 |
20090112853 | Ranking query processing method for stream data and stream data processing system having ranking query processing mechanism - A mechanism for managing ranking information using a sign of a stream tuple generated when stream data is inserted into, or deleted from, a window is provided. A mechanism for generating only the differential information of ranking calculation results, a mechanism for adding ranking information according to a request, an interface for generating and outputting all ranking information from the differential information, a mechanism for generating all ranking calculation results, and an interface for using these mechanisms are provided. | 04-30-2009 |
20090271529 | Stream data processing method and computer systems - Provided is a stream data processing method that can effectively handle delay data. In the stream data processing method of processing data whose lifetime is defined by a window, an operation result excluding a delay tuple is immediately output along with an unconfirmed flag according to delay processing HBT while a midway processing result necessary for reproduction is retained along with the lifetime, and when the delay tuple arrives, a correct processing result is calculated from the delay tuple and the processing result restore tuple. | 10-29-2009 |
20100106853 | MACHINE-READABLE MEDIUM FOR STORING A STREAM DATA PROCESSING PROGRAM AND COMPUTER SYSTEM - In a stream data processing method in which part of stream data is defined as a processing target and the time control information which indicates the advance of the time is inserted into the stream data, time information of the received stream data is stored in a next ignition time holding area as an ignition time. A processing module for generating the time control information at a time different from the time of reception of the stream data is extracted out of a query that indicates how the stream data is to be processed. Based on the extracted processing module and the time information indicating the time of the reception of the stream data, the ignition time is calculated and stored in the next ignition time holding area. The time generation module inserts the time control information at the ignition time held in the next ignition time holding area. | 04-29-2010 |
20100106946 | METHOD FOR PROCESSING STREAM DATA AND SYSTEM THEREOF - The present invention provides a method for processing stream data and a system thereof capable of implementing general data processing including recursive processing with low latency. In the system for processing stream data, a single operator graph is prepared from operator trees of a plurality of queries, an execution order of the operators is determined so that execution of a streaming operator is progressed in one way from an input to an output, the ignition time of an external ignition operator that inputs data from the outside of the system and an internal ignition operator that time-limitedly generates data is monitored, and an operator execution control unit repeats processing that completes the processing in the operator graph at the time according to the determined operator execution order, assuming the operator of the earliest ignition time as a start point. | 04-29-2010 |
20130173587 | METHOD FOR PROCESSING STREAM DATA AND SYSTEM THEREOF - A network interface receives stream data and a processor processes the stream data. The processor: constructs an operator graph comprising information regarding a plurality of operators for processing the stream data based on a query; assigns an operator execution order to the plurality of operators based on an inter-operator input and output relation, with respect to all of the operators on the operator graph; extracts a set of the operators that maintains the stream data assigned with a time stamp, a time of which is earlier than or equal to a reference time, in an input queue; and executes processing of the stream data assigned with the time stamp, having the earliest time, in the operator assigned a minimum operator graph execution order among the operators and maintaining the stream data assigned with the time stamp having the earliest time, among the extracted set of the operators. | 07-04-2013 |
20140289221 | METHOD FOR PROCESSING STREAM DATA AND SYSTEM THEREOF - A network interface receives stream data and a processor processes the stream data. The processor: constructs an operator graph comprising information regarding a plurality of operators for processing the stream data based on a query; assigns an operator execution order to the plurality of operators based on an inter-operator input and output relation, with respect to all of the operators on the operator graph; extracts a set of the operators that maintains the stream data assigned with a time stamp, a time of which is earlier than or equal to a reference time, in an input queue; and executes processing of the stream data assigned with the time stamp, having the earliest time, in the operator assigned a minimum operator graph execution order among the operators and maintaining the stream data assigned with the time stamp having the earliest time, among the extracted set of the operators. | 09-25-2014 |
Patent application number | Description | Published |
20100050011 | FAILURE RECOVERY METHOD - The reliability is improved at a low cost even in a virtualized server environment. The number of spare servers is reduced for improving the reliability and for saving a licensing fee for software on the spare servers. A server system comprises a plurality of physical servers on which a plurality of virtual servers run, a single standby server, a module for detecting an active virtual server, and a module for switching the correspondence of boot disks of virtualization modules for controlling virtual servers to the physical servers. When a physical server fails, the boot disk of the associated virtualization module is connected to a spare server to automatically activate on the spare server those virtual servers which have been active upon occurrence of the failure. | 02-25-2010 |
20110173491 | FAILURE RECOVERY METHOD - The reliability is improved at a low cost even in a virtualized server environment. The number of spare servers is reduced for improving the reliability and for saving a licensing fee for software on the spare servers. A server system comprises a plurality of physical servers on which a plurality of virtual servers run, a single standby server, a module for detecting an active virtual server, and a module for switching the correspondence of boot disks of virtualization modules for controlling virtual servers to the physical servers. When a physical server fails, the boot disk of the associated virtualization module is connected to a spare server to automatically activate on the spare server those virtual servers which have been active upon occurrence of the failure. | 07-14-2011 |
20130103976 | FAILURE RECORVERY METHOD - The reliability is improved at a low cost even in a virtualized server environment. The number of spare servers is reduced for improving the reliability and for saving a licensing fee for software on the spare servers. A server system comprises a plurality of physical servers on which a plurality of virtual servers run, a single standby server, a module for detecting an active virtual server, and a module for switching the correspondence of boot disks of virtualization modules for controlling virtual servers to the physical servers. When a physical server fails, the boot disk of the associated virtualization module is connected to a spare server to automatically activate on the spare server those virtual servers which have been active upon occurrence of the failure. | 04-25-2013 |
Patent application number | Description | Published |
20130132668 | VOLUME COPY MANAGEMENT METHOD ON THIN PROVISIONING POOL OF STORAGE SUBSYSTEM - Exemplary embodiments provide integrated thin provisioning pool for primary logical volume and secondary logical volume in a storage subsystem. A storage system comprises a processor; a memory; and a storage controller. In one embodiment, the storage controller is configured to allocate storage area from a first pool in response to a write request, and to control allocation of storage areas for a plurality of related data, which are to be allocated from the first pool, from different specified RAID groups in the first pool. In another embodiment, the storage controller is configured to allocate storage area from a first pool in response to a write request, and to control allocation of storage areas for a plurality of related data, which are to be allocated from the first pool, from different RAID groups in the first pool. | 05-23-2013 |
20130290367 | STREAM DATA PROCESSING METHOD WITH MULTIPLE WINDOWS ON SINGLE STREAM - Exemplary embodiments are directed to a combination of real time processing functions and batch time processing functions to process stream data. When a query is received with a target function, the target function is processed based on the utilization of both a real-time processing function and a batch time processing function. The real time processing functions may be executed by a sliding window, and the batch processing function may be executed by a jumping window. | 10-31-2013 |
20140181144 | STREAM DATA PROCESSING METHOD ON RECURSIVE QUERY OF GRAPH DATA - A stream data processing computer comprises: a query execution module to receive an input stream of stream data, manage execution order of operators for executing a query, and output an output stream, the operators including static recursive execution modules, a judge operator, and a dynamic recursive execution module; and a memory including a temporal store to store data generated in executing the query. The static recursive execution modules are configured to conduct a recursive number of static recursive execution of the query. The judge operator is configured to determine whether a preset condition is met after the recursive number of static recursive execution of the query. The dynamic recursive execution module is configured, if the preset condition is not met, to continue execution of the query by dynamic recursive execution from a last result of a last module of the static recursive execution modules, based on a dynamic recursive value. | 06-26-2014 |