Abstract:
PURPOSE: An explosion data stream processing meth and an apparatus thereof are provided to maintain the accuracy of a process result and to process data without the degradation of performance by processing the data stream. CONSTITUTION: A service managing module(312) manages task information allocated to a service and request information including QoS(Quality of Service) information about a service. A QoS monitoring module(313) collects execution state information about the allocated task. If the service does not satisfy threshold throughput of the QoS, the QoS monitoring module distinguishes a task which decreases process performance of the service. A scheduling module(314) divides data stream inputted to the task. [Reference numerals] (311) Service managing unit; (312) Service managing module; (313) QoS monitoring module; (314) Scheduling module; (322) Task managing module; (323) Area monitoring module; (401) Task 1; (402) Dividing task; (4031) Duplicated task 2-A; (4032) Duplicated task 2-B; (4033) Duplicated task 2-C; (406) Merging task; (407) Task 3; (AA) User; (BB) Data stream processing service request; (DD) Task information including a performance problem; (EE) Allocation, duplication, dynamic configuration; (FF) Data stream binding, control; (GG) Task execution unit; (HH) Task control command; (II) Monitoring; (JJ) Task execution state information
Abstract:
PURPOSE: Data processing method and apparatus are provided to satisfy quality of service(QoS) targets which are individualized according to each application service. CONSTITUTION: A data processing apparatus divides a plurality of operators based on each calculated maximum permissible delay time(320). The apparatus calculates QoS satisfaction margin with respect to the operators(330). The apparatus sets the execution sequence of the operators by reflecting the calculated QoS satisfaction margin(340). According to the execution sequence, the apparatus executes the operators(350).
Abstract:
A method for indexing and searching high dimensional data by using a signature file and a system thereof are provided to enhance a signature about a query feature vector and use the enhanced signature in searching, thereby increasing accuracy of the searching. Index generation related information including a feature vector of high dimensional data, an object identifier, a step signature file identifier and a two step signature file identifier is inputted(S401). A feature vector file including the feature vector and the object identifier is generated(S402). A two step signature is obtained by using 1 step signature information and feature vector(S405). The 2 step signature is stored in a 2 step signature file(S406).
Abstract:
A system and a method for processing stream data with software pre-filtering are provided to improve continuous query performance and prevent waste resource waste by previously filtering unneeded stream data out of user interests from the stream data continuously collected from dive sensors in a ubiquitous environment. Each data collector(220,225) collects the stream data for each external sensor(210). Each pre-filter(230,235) previously filters the stream data collected by each data collector. A continuous query processor(250) processes a continuous query for the stream data pre-filtered by the pre-filters. The pre-filter uses each buffer(240,245) of the data collectors as an input buffer and uses the buffer(260) of the continuous query processor as an output buffer.
Abstract:
본 발명은 연속되어 입력되는 XML 문서 스트림을 주기적으로 서비스(웹서비스, JMS) 호출로 연계하는 방법에 관한 것으로, 유비쿼터스 컴퓨팅 환경의 XML 데이터 스트림 처리기에서 XML 문서에 대한 연속질의(Continuous Query)의 결과로 생성되는 XML 문서를 서비스(웹서비스, JMS) 호출로 변환시킴으로써, 연속질의를 이용하여 정의한 컨텍스트(상황, 狀況)와 이에 대한 서비스(웹서비스, JMS)를 자동으로 연계할 수 있도록 하는 효과가 있다. XML 문서, 웹서비스, JMS, 유비쿼터스, 연속질의, 컨텍스트
Abstract:
본 발명은 XML 형태로 표현된 스트리밍 데이터 처리를 위한 XML 질의어 기반 연속 질의 언어 처리 시스템 및 방법에 관한 것으로서, 기존의 XML 질의어에 스트리밍 데이터 검색을 위하여 필요로 하는 기능을 추가하여 XML 질의 언어가 가지는 기본적인 특징은 유지하면서도 스트리밍 데이터를 접근할 수 있는 XML 질의어 기반 연속 질의 언어 처리 시스템 및 방법을 제공함으로써, 스트림 형태로 전송되는 데이터를 일관된 방식으로 처리할 수 있으며, 이력 데이터의 검색과 관련되어 기존의 XML 데이터 검색 시스템이 제공하는 API를 그대로 활용할 수 있다는 장점이 있다. XML, 센서, 스트리밍 데이터, 연속 질의
Abstract:
Provided are a method and an apparatus for processing applications with different data access patterns. A data management request is divided into one or more detailed requests. The detailed requests generated by the division are used to determine which data management engine among multiple data management engines can ensure the optimal execution performance. The data management engine which is determined to have the optimal execution performance executes the detailed requests. A result for the data management request is generated by collecting the results of executing the detailed requests.