公开(公告)号：KR1020130095910A

公开(公告)日：2013-08-29

申请号：KR1020120017309

申请日：2012-02-21

Applicant: 한국전자통신연구원

Inventor： 이명철 ,  최현화 ,  이훈순 ,  김병섭 ,  이미영

IPC: G06F9/46 ,  G06F9/38

CPC classification number: G06F9/5038 ,  G06F9/505

Abstract: PURPOSE: A data stream distribution parallelization processing service management device and a method thereof are provided to arrange plural tasks effectively by the load property, and to reduce the data input/output load among service tasks by the explosive increase of the input data stream forming the task comprising the service by using a communications means suitable for a task layout structure. CONSTITUTION: A service management unit(412) registers plural tasks comprising a data stream distribution parallelization processing service. A service quality monitoring unit(413) collects load information of the tasks, and load information of plural nodes forming a cluster which provides the data stream distribution parallelization processing service. A scheduling unit(414) distributes and arranges the tasks to the nodes based on the load information. [Reference numerals] (301) Task 1; (302) Task 2; (303) Task 3; (411) Task stream distribution parallelization processing service management device; (412) Service management unit; (413) Service quality monitoring unit; (414) Scheduling unit; (421,431,441) Task operating device; (422,432,442) Task management unit; (423,433,443) Local monitoring unit; (450) Input data stream source; (460) Output data stream source; (AA) Node 1; (BB) Node 2; (CC,DD) Node 3

Abstract translation: 目的：提供一种数据流分发并行化处理服务管理装置及其方法，通过负载特性有效地布置多个任务，并且通过形成输入数据流的爆炸性增加来减少服务任务之间的数据输入/输出负载 任务包括通过使用适合于任务布局结构的通信装置的服务。 构成：服务管理单元（412）登记包括数据流分配并行化处理服务的多个任务。 服务质量监控单元（413）收集任务的负载信息，并加载形成提供数据流分配并行处理服务的集群的多个节点的信息。 调度单元（414）根据负载信息将任务分配到节点。 （附图标记）（301）任务1; （302）任务2; （303）任务3; （411）任务流分发并行处理服务管理设备; （412）服务管理单位; （413）服务质量监控单位; （414）计划单位; （421,431,441）任务操作装置; （422,432,442）任务管理单位; （423,433,443）本地监测单位; （450）输入数据流源; （460）输出数据流源; （AA）节点1; （BB）节点2; （CC，DD）节点3

公开(公告)号：KR101266358B1

公开(公告)日：2013-05-22

申请号：KR1020080131285

申请日：2008-12-22

Applicant: 한국전자통신연구원

Inventor： 최현화 ,  이미영

IPC: G06F17/30 ,  G06F17/00

CPC classification number: G06F17/30961 ,  G06F17/30979

Abstract: 본발명은다중길이시그니처파일기반분산색인시스템및 방법에관한것으로서, 멀티미디어객체및 식별자로부터 N-차원의특징벡터를추출하는특징벡터추출수단, 상기멀티미디어객체의객체식별자와 N-차원의특징벡터에따른트리기반의분산색인을구성하고, 구성한분산색인트리의말단노드개수와기준클러스터의크기를비교하여시그니처의길이를결정하는분산색인관리수단및 상기결정한길이를반영한말단노드별시그니처를생성하여상기 N-차원의특징벡터와매칭하여저장하는고차원색인관리수단을포함하여구성한장치및 그방법을제공함으로써, 데이터의분포에따라분산색인트리내 단말의컴퓨팅노드가다른길이의시그니처파일을독자적으로구성할수 있어클러스터의크기가작은경우에더 많은비트로구성되는시그니처를생성함으로써, 효율적인검색을통해필터링효과를증대시키고, 분산색인트리의탐색을통해결정되는말단노드가하나이상인경우각 노드에서시그니처기반의필터링이병렬로수행되기때문에노드별다른길이의시그니처에따른추가비용이발생하지않고, 검색의정확도가증가한다는효과도얻어진다.

公开(公告)号：KR100778314B1

公开(公告)日：2007-11-22

申请号：KR1020060078905

申请日：2006-08-21

Applicant: 한국전자통신연구원

Inventor： 이명철 ,  최현화 ,  이미영 ,  김명준

IPC: G06F17/00 ,  G07F17/30

CPC classification number: G06F17/30516

Abstract: A system for performing an integrated continuous query process for data stream and stored data by using a user defined shared trigger and a method thereof are provided to reduce time for processing the stored data when integrated continuous queries are processed. A system for performing an integrated continuous query process for data stream and stored data by using a user defined shared trigger comprises a data stream manager(102), an integrated continuous query manager(107), a trigger manager(103), a trigger result manager(104), and an integrated continuous query executer(105). The data stream manager(102) manages the data stream inputted from an external device. The integrated continuous query manager(107) manages the integrated continuous queries inputted from an external application. The trigger manager(103) manages a user defined shared trigger inputted from an external application and registers the shared trigger at an external linked database. The trigger result manager(104) configures and manages trigger result sets resulted from performing the user defined shared trigger registered at the linked database. The integrated continuous query executer(105) processes the integrated continuous queries by referring to the data stream forwarded by the data stream manager(102) and the trigger result sets forwarded by the trigger result manager(104).

Abstract translation: 提供了一种用于通过使用用户定义的共享触发及其方法来执行数据流和存储数据的集成连续查询处理的系统，以在处理集成连续查询时减少处理所存储数据的时间。 一种用于通过使用用户定义的共享触发来执行用于数据流和存储数据的综合连续查询处理的系统包括数据流管理器（102），集成连续查询管理器（107），触发管理器（103），触发结果 经理（104）和综合连续查询执行器（105）。 数据流管理器（102）管理从外部设备输入的数据流。 综合连续查询管理器（107）管理从外部应用输入的综合连续查询。 触发管理器（103）管理从外部应用输入的用户定义的共享触发，并将共享触发记录在外部链接数据库。 触发结果管理器（104）配置和管理由执行在链接的数据库上注册的用户定义的共享触发而产生的触发结果集。 集成连续查询执行器（105）通过参考由数据流管理器（102）转发的数据流和由触发结果管理器（104）转发的触发结果集来处理集成的连续查询。

公开(公告)号：KR101793963B1

公开(公告)日：2017-11-07

申请号：KR1020140002836

申请日：2014-01-09

Applicant: 한국전자통신연구원

Inventor： 최현화 ,  김병섭 ,  배승조

IPC: G06F12/16 ,  G06F12/14 ,  G06F13/38 ,  G06F15/167

Abstract: 본발명은대용량메모리기반데이터처리를위한원격메모리데이터관리방법및 시스템에관한것으로서, 본발명에따른대용량메모리기반데이터처리를위한원격메모리데이터관리방법은복수의컴퓨팅노드들에장착된메모리를바탕으로대용량데이터처리를지원하는원격메모리시스템에서원격메모리데이터손실에따른응용프로그램의중지를방지하거나실행중지횟수를줄일수 있는대용량메모리기반데이터처리를한다. 본발명에따르면, 원격메모리에데이터를쓰고읽는경우에원격메모리를제공하는컴퓨팅노드및 원격메모리서버의오류발생시에도응용프로그램이중단되지않고지속실행되도록할 수있고, 긴실행시간이나대용량메모리를요구하는응용프로그램의안정적인실행을지원하여, 원격메모리시스템의활용을증대시킬수 있다.

Abstract translation: 本发明是基于安装在远程存储器存储，所述数据管理方法包括：多个计算节点，根据本发明涉及一种远程存储器，数据管理方法和系统，用于高容量基于存储器的数据处理的大容量的基于存储器的数据处理的 在支持大数据处理的远程存储器系统中，执行基于大存储器的数据处理以防止由于远程存储器数据丢失而导致应用程序停止或减少执行次数。 根据本发明，写入和读取数据传送到远程存储器运行持续甚至计算节点和一个错误发生在提供远程存储器远程存储器服务器时它可以不是应用程序被停止，并且需要很长的运行时间和大存储 为了支持应用程序的稳定执行，从而提高远程内存系统的利用率。

公开(公告)号：KR101770191B1

公开(公告)日：2017-08-23

申请号：KR1020130010378

申请日：2013-01-30

Applicant: 한국전자통신연구원

Inventor： 최현화 ,  배승조

IPC: G06F9/50 ,  G06F9/38 ,  G06F9/48

Abstract: 본발명의자원할당방법은, 작업간의선후관계를포함하는스케줄링정책을바탕으로실행하고자하는작업을선정하는과정과, 가용자원의상태정보, 선행작업의서비스실행시간, 기설정된예측실행시간및 선행실행임계치에의거하여상기선정된작업에대해가용한필요자원또는최적자원을결정하는과정과, 상기결정된필요자원또는최적자원에의거하여상기선정된작업에대한자원을할당하여실행시키는과정을포함할수 있다.

Abstract translation: 要执行基于所述调度政策本发明，状态信息，的先前作业的服务的执行时间，规定的预测的执行时间，并且处理前和用于作业的选择的可用资源的资源分配方法包括：工作之间的测序关系 在运行阈蒸馏可以包括确定所要求的资源的步骤的或最佳的资源永汉通过用于住在确定必要的资源或资源最佳的选择操作分配资源是用于选择和执行的操作 有。

公开(公告)号：KR1020160087706A

公开(公告)日：2016-07-22

申请号：KR1020150007012

申请日：2015-01-14

Applicant: 한국전자통신연구원

Inventor： 최현화 ,  김병섭 ,  배승조

IPC: G06F9/50 ,  G06F9/455

CPC classification number: G06F9/45558 ,  G06F9/5027 ,  G06F2009/4557 ,  G06F2209/502 ,  G06F9/5077 ,  G06F9/45533

Abstract: 본발명에따른가상화플랫폼을고려한분산데이터처리시스템의자원할당장치는선택된하나이상의태스크를실행할수 있는하나이상의가용가상머신을하나이상의물리머신에서검색하고, 수신된물리머신정보에기초하여가용가상머신사이의거리를산출하는자원사용감시부및 산출된가용가상머신사이의거리에기초하여검색된하나이상의가상머신에선택된하나이상의태스크를할당하는태스크할당부를포함한다.

Abstract translation: 考虑到根据本发明的虚拟化平台的分布式数据处理系统的资源分配装置包括：资源使用观察部分，其搜索可以在一个或多个物理机器中执行一个或多个所选任务的一个或多个可用虚拟机 并根据接收的物理机器信息计算可用虚拟机之间的距离; 以及任务分配部分，其基于所计算的可用虚拟机之间的距离，分配由一个或多个虚拟机选择的一个或多个任务，所述虚拟机被搜索。

公开(公告)号：KR1020150139017A

公开(公告)日：2015-12-11

申请号：KR1020140066373

申请日：2014-05-30

Applicant: 한국전자통신연구원

Inventor： 김병섭 ,  배승조 ,  최현화

IPC: G06F12/02

CPC classification number: G06F12/10

Abstract: 본발명의일 실시예에따른메모리제어장치는페이지단위의데이터를저장하는보조저장장치, 페이지정보를저장하는메모리및 데이터중 접근대상데이터에대한페이지폴트가발생하는경우, 페이지정보를수정하는스왑아웃(swap out)을수행하고, 메모리의미할당영역에접근대상데이터를적재하는프로세서를포함한다.

Abstract translation: 根据本发明的实施例，存储器控制装置包括：用于存储页面单元数据的辅助存储装置; 用于存储页面信息的存储器; 以及处理器，用于执行交换以修改页面信息，并且在数据的访问目标数据发生页面错误时，将访问目标数据累积到存储器的未分配区域中。

公开(公告)号：KR1020110066705A

公开(公告)日：2011-06-17

申请号：KR1020090123461

申请日：2009-12-11

Applicant: 한국전자통신연구원 ,  전북대학교산학협력단

Inventor： 최현화 ,  김영창 ,  이미영 ,  엄정호 ,  장재우

IPC: G06F17/40 ,  G06F17/30

CPC classification number: G06F17/30784 ,  G06F17/3033 ,  G06F17/30592

Abstract: PURPOSE: An index and a searching method of high dimensional feature vector data of a Dual Min-LSH algorithm is provided to guarantee QoS to a user by keeping the accuracy over a determined level and reducing the search time. CONSTITUTION: A hash table comprises a Low hash table(226) and a High hash table(228). The Low hash table calculates and stores a MinHash value of higher ordered data on the basis of permutations of arbitrary numbers. The High hash table calculates and stores the MinHash value of higher ordered data on the basis of more permutations including the permutations of the Low hash table for data within a bucket exceeding the number of entries of a threshold in the Low hash table.

Abstract translation: 目的：提供双Min-LSH算法的高维特征向量数据的索引和搜索方法，以通过将精度保持在确定的水平并减少搜索时间来保证用户的QoS。 构成：散列表包括低散列表（226）和高散列表（228）。 低散列表基于任意数字的排列来计算并存储较高数据的MinHash值。 高散列表基于更多排列来计算和存储较高排序数据的MinHash值，其中包括对于桶内的数据的低散列表的排列超过低散列表中阈值的条目数。

公开(公告)号：KR100789771B1

公开(公告)日：2007-12-28

申请号：KR1020060024423

申请日：2006-03-16

Applicant: 한국전자통신연구원

Inventor： 최현화 ,  이미영 ,  이명철 ,  김명준

IPC: G06F17/30

Abstract: 1. 청구범위에 기재된 발명이 속한 기술분야
본 발명은 트리거를 이용한 입력 데이터 스트림과 저장 데이터의 통합 질의 처리 시스템 및 그 방법에 관한 것임.
2. 발명이 해결하려고 하는 기술적 과제
본 발명은 연속적으로 입력되는 데이터 스트림과 데이터베이스의 저장 데이터를 통합하여 연속 질의 처리하되, 트리거(trigger)를 이용하여 상기 저장 데이터를 실시간으로 사전 처리해 둠으로써, 통합 질의 처리시 저장 데이터 처리에 소요되는 시간을 줄여 전체 성능이 향상되도록 하기 위한, 트리거를 이용한 입력 데이터 스트림과 저장 데이터의 통합 질의 처리 시스템 및 그 방법을 제공하는데 그 목적이 있음.
3. 발명의 해결방법의 요지
본 발명은, 통합 질의 처리 시스템에 있어서, 외부로부터 연속적으로 입력되는 데이터 스트림을 관리하기 위한 데이터 스트림 관리 수단; 연동 데이터베이스에 트리거를 등록하고, 상기 등록된 트리거의 수행 결과로 결과 집합을 구성하여 실시간 제공하기 위한 트리거 결과 관리 수단; 및 상기 데이터 스트림 관리 수단으로부터 전달받는 데이터 스트림과 상기 연동 데이터베이스의 저장 데이터에 대한 통합 질의를 처리하되, 상기 연동 데이터베이스의 저장 데이터에 대해서는 상기 트리거 결과 관리 수단으로부터 전달받는 결과 집합을 참조하여 통합 질의를 처리하기 위한 실행 수단을 포함한다.
4. 발명의 중요한 용도
본 발명은 데이터 스트림 처리 시스템 등에 이용됨.
통합 연속 질의, XML 데이터 스트림 처리 시스템, 트리거

公开(公告)号：KR1020070060992A

公开(公告)日：2007-06-13

申请号：KR1020060024423

申请日：2006-03-16

Applicant: 한국전자통신연구원

Inventor： 최현화 ,  이미영 ,  이명철 ,  김명준

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数据库时自动执行的触发器形成结果集。