-
公开(公告)号：KR1020160142102A
公开(公告)日：2016-12-12
申请号：KR1020150078030
申请日：2015-06-02
Applicant: 한국전자통신연구원
CPC classification number: G06F9/5083 , G06F17/30327 , G06F17/30516
Abstract: 본발명의실시예들은, 분산스트림처리서비스를관리하는방법및 장치에관한것으로, 본발명의일 실시예에따른분산스트림처리서비스병합방법은, 하나의분산스트림처리서비스를기반으로전역서비스트리를생성하는단계; 상기하나의분산스트림처리서비스와는상이한분산스트림처리서비스가입력될때마다해당분산스트림처리서비스에대한개별서비스트리를생성하는단계; 및상기전역서비스트리와상기개별서비스트리에공통으로존재하는적어도하나의노드를병합함으로써상기전역서비스트리를갱신하는단계를포함한다. 본발명의실시예들에따르면, 분산스트림처리서비스들간에공통으로존재하는태스크(또는인스턴스)들에공통된자원을할당할수 있다.
Abstract translation: 以下描述涉及用于合并分布式流处理服务的方法和装置。 根据示例的用于合并分布式流处理服务的方法包括：基于一个分布式流处理服务生成全局服务树; 当输入与一个分布式流处理服务不同的新的分布式流处理服务时，为新的分布式流处理服务生成一个单独的服务树; 以及通过合并至少一个在全球服务树和单个服务树中存在的一个节点来更新全局服务树。 公共资源可以分配给分布式流处理服务中通常存在的任务（或实例）。
-
公开(公告)号：KR100907533B1
公开(公告)日：2009-07-14
申请号：KR1020070132586
申请日：2007-12-17
Applicant: 한국전자통신연구원
IPC: G06F15/16 , H04L12/865
Abstract: 본 발명은 특정 맵 태스크 수행기에 중간 결과 전송 요청이 집중되는 것을 효율적으로 방지하면서 로그 시간 복잡도를 가지도록 하여 성능을 향상시킬 수 있는 작업 분산 병렬 처리 시스템 및 방법을 제공하는 것으로, 본 발명의 작업 분산 병렬 처리 시스템은, 맵 태스크를 수행하여 전송예정 중간 결과를 생성하고 중간 결과 경로 정보를 네트워크를 통해 통보하는 다수의 맵 태스크 수행기들; 상기 중간 결과 경로 정보를 상기 네트워크를 통해 각 리듀스 태스크에게 통보하는 작업 관리기; 및 상기 작업 관리기로부터 상기 중간 결과 경로 정보를 통보받고, 전송예정 중간결과들을 맵 태스크의 식별자 순서에 따라 우선순위 큐 내에 영역 별로 분리 할당하고, 상기 우선순위 큐의 영역들의 전송예정 중간결과들을 우선순위 별로 선택하는 다수의 리듀스 태스크 수행기들;을 포함하는 것을 특징으로 한다.
맵태스크, 우선순위큐, 영역분할, 로그시간복잡도, 리듀스태스크Abstract translation: 提供了一种分布式并行任务处理系统及其方法，以有效地避免中间结果传输请求集中在特定的地图任务执行设备上，并且具有日志时间复杂度，从而提高了性能。 多个简化任务执行设备（131〜133）从任务管理设备（120）接收中间结果路径信息的通知。 根据地图任务的标识符顺序，减少任务执行设备将传输计划中间结果分割成每个区域的优先级队列。 减少任务执行设备根据优先级来选择优先队列的区域的传输计划中间结果。
-
公开(公告)号：KR100789771B1
公开(公告)日：2007-12-28
申请号：KR1020060024423
申请日：2006-03-16
Applicant: 한국전자통신연구원
IPC: G06F17/30
Abstract: 1. 청구범위에 기재된 발명이 속한 기술분야
본 발명은 트리거를 이용한 입력 데이터 스트림과 저장 데이터의 통합 질의 처리 시스템 및 그 방법에 관한 것임.
2. 발명이 해결하려고 하는 기술적 과제
본 발명은 연속적으로 입력되는 데이터 스트림과 데이터베이스의 저장 데이터를 통합하여 연속 질의 처리하되, 트리거(trigger)를 이용하여 상기 저장 데이터를 실시간으로 사전 처리해 둠으로써, 통합 질의 처리시 저장 데이터 처리에 소요되는 시간을 줄여 전체 성능이 향상되도록 하기 위한, 트리거를 이용한 입력 데이터 스트림과 저장 데이터의 통합 질의 처리 시스템 및 그 방법을 제공하는데 그 목적이 있음.
3. 발명의 해결방법의 요지
본 발명은, 통합 질의 처리 시스템에 있어서, 외부로부터 연속적으로 입력되는 데이터 스트림을 관리하기 위한 데이터 스트림 관리 수단; 연동 데이터베이스에 트리거를 등록하고, 상기 등록된 트리거의 수행 결과로 결과 집합을 구성하여 실시간 제공하기 위한 트리거 결과 관리 수단; 및 상기 데이터 스트림 관리 수단으로부터 전달받는 데이터 스트림과 상기 연동 데이터베이스의 저장 데이터에 대한 통합 질의를 처리하되, 상기 연동 데이터베이스의 저장 데이터에 대해서는 상기 트리거 결과 관리 수단으로부터 전달받는 결과 집합을 참조하여 통합 질의를 처리하기 위한 실행 수단을 포함한다.
4. 발명의 중요한 용도
본 발명은 데이터 스트림 처리 시스템 등에 이용됨.
통합 연속 질의, XML 데이터 스트림 처리 시스템, 트리거-
公开(公告)号：KR1020070060992A
公开(公告)日：2007-06-13
申请号：KR1020060024423
申请日：2006-03-16
Applicant: 한국전자통신연구원
IPC: G06F17/30
Abstract: A system and a method for processing an integrated query for an input data stream and stored data by using a trigger are provided to improve entire performance by reducing time required for processing the stored data when the integrated query is processed, as the data stored in a database is preprocessed in real-time by using the trigger. A data stream manager(102) manages the data stream continuously inputted from the outside. A triggering result set manager(104) registers the triggers(TR1-TRn) to an XML(eXtensible Markup Language) database(103), forms a result set with an execution result of the registered triggers, and provides the result set in real-time. An integrated continuous query executor(105) processes the integrated query by referring to the received result set for the data stored in the XML database while processing the integrated query for the received data stream and the data stored in the XML database. The triggering result manager forms the result set for the triggers automatically executed when the XML database is changed.
Abstract translation: 提供了一种用于通过使用触发来处理输入数据流和存储数据的集成查询的系统和方法，以通过减少处理集成查询时处理存储数据所需的时间来改善整体性能，作为存储在 数据库通过使用触发器实时预处理。 数据流管理器（102）管理从外部连续输入的数据流。 触发结果集管理器（104）将触发器（TR1-TRn）注册到XML（可扩展标记语言）数据库（103），形成具有注册触发器的执行结果的结果集， 时间。 集成的连续查询执行器（105）通过参考存储在XML数据库中的数据的接收结果集来处理集成查询，同时处理接收到的数据流的集成查询和存储在XML数据库中的数据。 触发结果管理器为更改XML数据库时自动执行的触发器形成结果集。
-
公开(公告)号：KR100691261B1
公开(公告)日：2007-03-12
申请号：KR1020060033726
申请日：2006-04-13
Applicant: 한국전자통신연구원
Abstract: A system and a method for processing update of XML(eXtensible Markup Language) are provided to support XQuery update for XML schema, which is defined according to a basic SQL(Structured Query Language)/XML mapping rule, by an XML DBMS(DataBase Management System) of relational database basis in order to perform a query operation of XML data managed by a relational database with an XQuery(XML Query). A parser(123) generates an XQuery update context analysis tree by parsing an XQuery sentence received from the outside. A verifier(124) verifies validity of the received XQuery sentence by rounding the XQuery update context analysis tree. A converter(125) converts the XQuery update context analysis tree into an XQuery update query tree by rounding the XQuery update context analysis tree based on verification of the verifier. An executor(126) executes the relational database query sentence to the relational database(130) connected to the outside by generating the relational database query sentence while rounding the XQuery update query tree.
Abstract translation: 提供了一种用于处理XML（可扩展标记语言）更新的系统和方法，以支持通过XML DBMS（数据库管理器）根据基本SQL（结构化查询语言）/ XML映射规则定义的XML模式的XQuery更新 系统），以使用XQuery（XML查询）执行关系数据库管理的XML数据的查询操作。 解析器（123）通过解析从外部接收到的XQuery语句来生成XQuery更新上下文分析树。 验证者（124）通过舍入XQuery更新上下文分析树来验证接收到的XQuery语句的有效性。 A转换器（125）通过基于验证者的验证对XQuery更新上下文分析树进行舍入，将XQuery更新上下文分析树转换为XQuery更新查询树。 执行器（126）通过在四舍五入XQuery更新查询树的同时生成关系数据库查询语句来将关系数据库查询语句执行到连接到外部的关系数据库（130）。
-
Patent Agency Ranking
公开(公告)号：KR1020060071288A
公开(公告)日：2006-06-26
申请号：KR1020050060180
申请日：2005-07-05
Applicant: 한국전자통신연구원
CPC classification number: G06F17/30914 , G06F17/227 , G06F17/30002 , G06F17/30932
Abstract: 본 발명은 XML(eXtended Markup Language) 기반 센서 데이터 스트림 처리 프레임워크 및 방법에 관한 것으로, 다양한 종류의 센서들로부터 들어오는 데이터 스트림에 대하여 다양한 조건들로 구성되는 이벤트(즉, 특정 상황의 발생 여부)를 정의할 수 있고, 특정 이벤트 발생시 적용해야 하는 서비스를 정의하여, 이를 실행할 수 있도록 함으로써, 다양한 유비쿼터스 서비스 환경을 쉽게 구축할 수 있다.
또한, 본 발명의 XML 기반 센서 데이터 스트림 처리 프레임워크 및 방법은, 표현력이 뛰어나고 융통성이 있는 XML모델을 기반으로 센서 데이터를 처리하도록 구성되어 있으므로 다양한 형식의 센서 데이터를 제공하는 각종 센서들과의 연동이 용이하다. 또한, 연동된 센서들로부터 들어오는 대용량의 센서 데이터 스트림을 실시간으로 처리하여 유비쿼터스 환경의 다양한 응용에서 요구하는 실시간 정보를 제공해 줌으로써, 서비스 제공자가 용용 서비스 개발에만 전념할 수 있도록 한다.
XML, 센서 데이터, 스트림 처리, 이벤트, 프레임워크, 유비쿼터스-
公开(公告)号：KR1020030054605A
公开(公告)日：2003-07-02
申请号：KR1020010084801
申请日：2001-12-26
Applicant: 한국전자통신연구원
IPC: G06F17/30
Abstract: PURPOSE: An XML document search system and a method for the same are provided to enable a user to search for an XML document in a database, storing plural XML documents, by using an integrated query which tightly couples an XML query with a database query. CONSTITUTION: The system comprises a search management module(110), a syntax analysis module(120), a query process module(130), a result process module(140) and a database engine(200). The search management module(110) performs a function of an interface with the database engine(200), and controls the syntax analysis module(120), the query process module(130), and the result process module(140). The syntax analysis module(120) analyzes the syntax on the XML query input via the search management module(110), checks whether the input XML query follows a preset query context rule, and generates a syntax tree for the input XML query in a case that the input XML query does not follow the preset query context rule. At this time the syntax analysis module(120) receives the integrated query which tightly couples the XML query with a database query, and checks an effectiveness of the input XML query. The query process module(130) processes the XML query by using the generated syntax tree. The result process module(140) converts the query process result of the query process module(130) into the type appropriate for the database engine(200), and transmits the converted result to the search management module(110).
Abstract translation: 目的：提供XML文档搜索系统及其方法，以使用户能够通过使用将XML查询与数据库查询紧密耦合的集成查询来搜索数据库中的XML文档，存储多个XML文档。 构成：系统包括搜索管理模块（110），语法分析模块（120），查询处理模块（130），结果处理模块（140）和数据库引擎（200）。 搜索管理模块（110）执行与数据库引擎（200）的接口的功能，并且控制语法分析模块（120），查询处理模块（130）和结果处理模块（140）。 语法分析模块（120）分析经由搜索管理模块（110）输入的XML查询的语法，检查输入的XML查询是否遵循预设的查询上下文规则，并且在一种情况下生成用于输入XML查询的语法树 输入XML查询不遵循预设查询上下文规则。 此时，语法分析模块（120）接收将XML查询与数据库查询紧密耦合的综合查询，并检查输入XML查询的有效性。 查询处理模块（130）通过使用生成的语法树处理XML查询。 结果处理模块（140）将查询处理模块（130）的查询处理结果转换成适用于数据库引擎（200）的类型，并将转换的结果发送到搜索管理模块（110）。
-
公开(公告)号：KR101827369B1
公开(公告)日：2018-02-09
申请号：KR1020120017309
申请日：2012-02-21
Applicant: 한국전자통신연구원
CPC classification number: G06F9/5038 , G06F9/505
Abstract: 데이터스트림분산병렬처리서비스관리장치및 방법이개시된다. 본발명에따른데이터스트림분산병렬처리서비스관리장치는, 데이터스트림분산병렬처리서비스를구성하는복수의태스크들을등록하는서비스관리부; 상기복수의태스크들의부하정보및 상기데이터스트림분산병렬처리서비스를제공하는클러스터를구성하는복수의노드들의부하정보를수집하는서비스품질모니터링부; 및상기복수의태스크들의부하정보및 상기복수의노드들의부하정보에근거하여상기복수의태스크들을상기복수의노드들에분산배치하는스케쥴링부를포함한다.
Abstract translation: 公开了一种数据流分布式并行处理服务管理装置和方法。 根据本发明的数据流分配并行处理服务管理装置包括：服务管理单元，用于注册构成数据流分布式并行处理服务的多个任务; 服务质量监视单元，用于收集构成提供数据流分布式并行处理服务的集群的多个任务的负载信息和负载信息; 以及调度单元，其基于所述多个任务的负载信息和所述多个节点的负载信息将所述多个任务分发到所述多个节点。
-
公开(公告)号：KR101752699B1
公开(公告)日：2017-07-03
申请号：KR1020110071031
申请日：2011-07-18
Applicant: 한국전자통신연구원
Abstract: 본발명에따른폭증데이터스트림처리방법및 장치가개시된다. 본발명에따른폭증데이터스트림처리방법은데이터스트림의폭증을처리하기위한데이터스트림처리방법으로, 데이터스트림처리서비스를수행하는태스크들의실행상태정보를수집하는제 1 단계상기태스크의실행상태정보에기초하여, 상기서비스가미리정해진처리성능조건을만족하지못한다고판단되는경우, 실행중인태스크중 상기서비스의처리성능저하의원인이되는태스크를판별하는제 2 단계및 상기판별된태스크로입력되는데이터스트림을분할하여병렬처리될수 있도록상기서비스내의태스크를동적으로재구성하는제 3단계를포함하여구성된다. 본발명에따른폭증데이터스트림처리방법및 장치를사용하면, 폭증데이터스트림의데이터처리연산을동적으로다중복제하고, 데이터스트림을분할하여복제된연산에서분산처리토록하여, 데이터가병렬처리되도록함으로써, 처리결과의정확도를유지하면서성능의저하가없는데이터처리를가능하게한다.
-
公开(公告)号：KR101285078B1
公开(公告)日：2013-07-17
申请号：KR1020090126035
申请日：2009-12-17
Applicant: 한국전자통신연구원
CPC classification number: G06F9/5027 , G06F15/17393 , G06F2209/5017
Abstract: 대용량의 데이터를 다수의 컴퓨팅 노드를 이용하여 MapReduce 방식으로 분산 병렬 처리하는 시스템으로서, 이미 수집되어 있는 대용량 저장 데이터는 물론 분산 병렬 처리 작업이 수행되는 동안에도 연속적으로 수집되는 대량의 스트림 데이터에 대해서 점진적인 MapReduce 기반 분산 병렬 처리 기능을 제공하기 위한 분산 병렬 처리 시스템이 제공된다.
분산 병렬 처리, 스트림 데이터, MapReduce, Incremental
-
-
-
-
-
-
-
-
-
Search Results
39
records
(took 0.026 seconds)
