맞춤기술찾기

이전대상기술

분산 스트림 처리 서비스 병합 방법 및 장치(Distributed stream processing services merging method and apparatus thereof)

  • 기술번호 : KST2016020401
  • 담당센터 : 대전기술혁신센터
  • 전화번호 : 042-610-2279
요약, Int. CL, CPC, 출원번호/일자, 출원인, 등록번호/일자, 공개번호/일자, 공고번호/일자, 국제출원번호/일자, 국제공개번호/일자, 우선권정보, 법적상태, 심사진행상태, 심판사항, 구분, 원출원번호/일자, 관련 출원번호, 기술이전 희망, 심사청구여부/일자, 심사청구항수의 정보를 제공하는 이전대상기술 뷰 페이지 상세정보 > 서지정보 표입니다.
요약 본 발명의 실시 예들은, 분산 스트림 처리 서비스를 관리하는 방법 및 장치에 관한 것으로, 본 발명의 일 실시 예에 따른 분산 스트림 처리 서비스 병합 방법은, 하나의 분산 스트림 처리 서비스를 기반으로 전역 서비스 트리를 생성하는 단계; 상기 하나의 분산 스트림 처리 서비스와는 상이한 분산 스트림 처리 서비스가 입력될 때마다 해당 분산 스트림 처리 서비스에 대한 개별 서비스 트리를 생성하는 단계; 및 상기 전역 서비스 트리와 상기 개별 서비스 트리에 공통으로 존재하는 적어도 하나의 노드를 병합함으로써 상기 전역 서비스 트리를 갱신하는 단계를 포함한다. 본 발명의 실시 예들에 따르면, 분산 스트림 처리 서비스들 간에 공통으로 존재하는 태스크(또는 인스턴스)들에 공통된 자원을 할당할 수 있다.
Int. CL G06F 9/50 (2006.01) G06F 17/30 (2006.01)
CPC G06F 9/5066(2013.01) G06F 9/5066(2013.01) G06F 9/5066(2013.01)
출원번호/일자 1020150078030 (2015.06.02)
출원인 한국전자통신연구원
등록번호/일자
공개번호/일자 10-2016-0142102 (2016.12.12) 문서열기
공고번호/일자
국제출원번호/일자
국제공개번호/일자
우선권정보
법적상태 공개
심사진행상태 수리
심판사항
구분 신규
원출원번호/일자
관련 출원번호
심사청구여부/일자 N
심사청구항수 20

출원인

번호, 이름, 국적, 주소의 정보를 제공하는 이전대상기술 뷰 페이지 상세정보 > 인명정보 - 출원인 표입니다.
번호 이름 국적 주소
1 한국전자통신연구원 대한민국 대전광역시 유성구

발명자

번호, 이름, 국적, 주소의 정보를 제공하는 이전대상기술 뷰 페이지 상세정보 > 인명정보 - 발명자 표입니다.
번호 이름 국적 주소
1 이명철 대한민국 대전광역시 유성구
2 이미영 대한민국 대전광역시 유성구

대리인

번호, 이름, 국적, 주소의 정보를 제공하는 이전대상기술 뷰 페이지 상세정보 > 인명정보 - 대리인 표입니다.
번호 이름 국적 주소
1 팬코리아특허법인 대한민국 서울특별시 강남구 논현로**길 **, 역삼***빌딩 (역삼동)

최종권리자

번호, 이름, 국적, 주소의 정보를 제공하는 이전대상기술 뷰 페이지 상세정보 > 인명정보 - 최종권리자 표입니다.
번호 이름 국적 주소
최종권리자 정보가 없습니다
번호, 서류명, 접수/발송일자, 처리상태, 접수/발송일자의 정보를 제공하는 이전대상기술 뷰 페이지 상세정보 > 행정처리 표입니다.
번호 서류명 접수/발송일자 처리상태 접수/발송번호
1 [특허출원]특허출원서
[Patent Application] Patent Application
2015.06.02 수리 (Accepted) 1-1-2015-0532237-13
2 [대리인선임]대리인(대표자)에 관한 신고서
[Appointment of Agent] Report on Agent (Representative)
2016.10.13 수리 (Accepted) 1-1-2016-0994010-04
번호, 청구항의 정보를 제공하는 이전대상기술 뷰 페이지 상세정보 > 청구항 표입니다.
번호 청구항
1 1
하나의 분산 스트림 처리 서비스를 기반으로 전역 서비스 트리를 생성하는 단계; 상기 하나의 분산 스트림 처리 서비스와는 상이한 분산 스트림 처리 서비스가 입력될 때마다 해당 분산 스트림 처리 서비스에 대한 개별 서비스 트리를 생성하는 단계; 및 상기 전역 서비스 트리와 상기 개별 서비스 트리에 공통으로 존재하는 적어도 하나의 노드를 병합함으로써 상기 전역 서비스 트리를 갱신하는 단계를 포함하는 분산 스트림 처리 서비스 병합 방법
2 2
제 1 항에 있어서, 상기 전역 서비스 트리를 갱신하는 단계는, 상기 전역 서비스 트리와 상기 개별 서비스 트리 각각의 최상위 노드부터 순차적으로 비교를 수행하여, 상기 전역 서비스 트리와 상기 개별 서비스 트리에 공통으로 존재하는 노드들이 있는지 확인하는 단계를 포함하는 분산 스트림 처리 서비스 병합 방법
3 3
제 2 항에 있어서, 상기 공통으로 존재하는 노드들이 있는지 확인하는 단계는, 최상위 노드부터 시작되는 일련의 공통된 노드들이 있는지 확인하는 단계를 포함하는 분산 스트림 처리 서비스 병합 방법
4 4
제 3 항에 있어서, 상기 전역 서비스 트리를 갱신하는 단계는, 상기 일련의 공통된 노드들 중 최하위 노드를 병합 기준 노드로 결정하는 단계; 및 상기 개별 서비스 트리에 존재하는 병합 기준 노드의 하위에 연결된 서브 트리를, 상기 전역 서비스 트리에 존재하는 병합 기준 노드의 하위에 추가하는 단계를 포함하는 분산 스트림 처리 서비스 병합 방법
5 5
제 1 항에 있어서, 상기 전역 서비스 트리에 반영된 분산 스트림 처리 서비스 중 어느 하나의 분산 스트림 처리 서비스에 대한 삭제 요청이 있는 경우, 해당 분산 스트림 처리 서비스에만 이용되는 노드를 상기 전역 서비스 트리에서 삭제함으로써 상기 전역 서비스 트리를 갱신하는 단계를 더 포함하는 분산 스트림 처리 서비스 병합 방법
6 6
제 1 항에 있어서, 상기 전역 서비스 트리에 존재하는 각각의 노드들에 대하여, 해당 노드가 몇 개의 분산 스트림 처리 서비스에 이용되는지를 나타내는 참조 카운트를 설정하는 단계를 더 포함하는 분산 스트림 처리 서비스 병합 방법
7 7
제 6 항에 있어서, 상기 참조 카운트가 설정 값 이상인 노드가 있는 경우, 해당 노드의 하위에 연결된 서브 트리들 중 어느 하나의 서브 트리를 해당 노드의 상위 노드에 연결하는 단계를 더 포함하는 분산 스트림 처리 서비스 병합 방법
8 8
제 6 항에 있어서, 상기 전역 서비스 트리에 반영된 분산 스트림 처리 서비스 중 어느 하나의 분산 스트림 처리 서비스에 대한 삭제 요청이 있는 경우, 해당 분산 스트림 처리 서비스에만 이용되는 노드를 상기 전역 서비스 트리에서 삭제함으로써 상기 전역 서비스 트리를 갱신하는 단계를 더 포함하는 분산 스트림 처리 서비스 병합 방법
9 9
제 8 항에 있어서, 상기 전역 서비스 트리에서 삭제하는 단계는, 상기 전역 서비스 트리와 상기 삭제 요청된 분산 스트림 서비스 트리 각각의 최상위 노드부터 순차적으로 비교를 수행하여, 참조 카운트가 1인 공통 노드가 있는 경우 해당 공통 노드 및 해당 공통 노드의 하위에 연결된 서브 트리를 상기 전역 서비스 트리에서 삭제하는 단계; 및 참조 카운트가 2 이상인 공통 노드가 있는 경우 해당 공통 노드의 참조 카운트를 1 감소시키는 단계를 포함하는 분산 스트림 처리 서비스 병합 방법
10 10
제 1 항에 있어서, 상기 갱신된 전역 서비스 트리에 존재하는 서브 트리들을 서로 다른 서버에 분산 배치하는 단계를 더 포함하는 분산 스트림 처리 서비스 병합 방법
11 11
하나의 분산 스트림 처리 서비스를 기반으로 전역 서비스 트리를 생성하고, 상기 하나의 분산 스트림 처리 서비스와는 상이한 분산 스트림 처리 서비스가 입력될 때마다 해당 분산 스트림 처리 서비스에 대한 개별 서비스 트리를 생성하며, 상기 전역 서비스 트리와 상기 개별 서비스 트리에 공통으로 존재하는 적어도 하나의 노드를 병합함으로써 상기 전역 서비스 트리를 갱신하는 전역 서비스 트리 관리자; 및 상기 갱신된 전역 서비스 트리를 기반으로 자원 할당을 수행하는 스케쥴러를 포함하는 분산 스트림 처리 서비스 병합 장치
12 12
제 11 항에 있어서, 상기 전역 서비스 트리 관리자는, 상기 전역 서비스 트리와 상기 개별 서비스 트리 각각의 최상위 노드부터 순차적으로 비교를 수행하여, 상기 전역 서비스 트리와 상기 개별 서비스 트리에 공통으로 존재하는 노드들이 있는지 확인하는 분산 스트림 처리 서비스 병합 장치
13 13
제 12 항에 있어서, 상기 전역 서비스 트리 관리자는, 최상위 노드부터 시작되는 일련의 공통된 노드들이 있는지 확인하는 분산 스트림 처리 서비스 병합 장치
14 14
제 13 항에 있어서, 상기 전역 서비스 트리 관리자는, 상기 일련의 공통된 노드들 중 최하위 노드를 병합 기준 노드로 결정하고, 상기 개별 서비스 트리에 존재하는 병합 기준 노드의 하위에 연결된 서브 트리를 상기 전역 서비스 트리에 존재하는 병합 기준 노드의 하위에 추가하는 분산 스트림 처리 서비스 병합 장치
15 15
제 11 항에 있어서, 상기 전역 서비스 트리 관리자는, 상기 전역 서비스 트리에 반영된 분산 스트림 처리 서비스 중 어느 하나의 분산 스트림 처리 서비스에 대한 삭제 요청이 있는 경우, 해당 분산 스트림 처리 서비스에만 이용되는 노드를 상기 전역 서비스 트리에서 삭제함으로써 상기 전역 서비스 트리를 갱신하는 분산 스트림 처리 서비스 병합 장치
16 16
제 11 항에 있어서, 상기 전역 서비스 트리 관리자는, 상기 전역 서비스 트리에 존재하는 각각의 노드들에 대하여, 해당 노드가 몇 개의 분산 스트림 처리 서비스에 이용되는지를 나타내는 참조 카운트를 설정하는 분산 스트림 처리 서비스 병합 장치
17 17
제 16 항에 있어서, 상기 전역 서비스 트리 관리자는, 상기 참조 카운트가 설정 값 이상인 노드가 있는 경우, 해당 노드의 하위에 연결된 서브 트리들 중 어느 하나의 서브 트리를 해당 노드의 상위 노드에 연결하는 분산 스트림 처리 서비스 병합 장치
18 18
제 16 항에 있어서, 상기 전역 서비스 트리 관리자는, 상기 전역 서비스 트리에 반영된 분산 스트림 처리 서비스 중 어느 하나의 분산 스트림 처리 서비스에 대한 삭제 요청이 있는 경우, 해당 분산 스트림 처리 서비스에만 이용되는 노드를 상기 전역 서비스 트리에서 삭제함으로써 상기 전역 서비스 트리를 갱신하는 분산 스트림 처리 서비스 병합 장치
19 19
제 18 항에 있어서, 상기 전역 서비스 트리 관리자는, 상기 전역 서비스 트리와 상기 삭제 요청된 분산 스트림 서비스 트리 각각의 최상위 노드부터 순차적으로 비교를 수행하여 참조 카운트가 1인 공통 노드가 있는 경우 해당 공통 노드 및 해당 공통 노드의 하위에 연결된 서브 트리를 상기 전역 서비스 트리에서 삭제하고, 참조 카운트가 2 이상인 공통 노드가 있는 경우 해당 공통 노드의 참조 카운트를 1 감소시키는 분산 스트림 처리 서비스 병합 장치
20 20
제 11 항에 있어서, 상기 스케쥴러는, 상기 갱신된 전역 서비스 트리에 존재하는 서브 트리들을 서로 다른 서버에 분산 배치하는 분산 스트림 처리 서비스 병합 장치
지정국 정보가 없습니다
순번, 패밀리번호, 국가코드, 국가명, 종류의 정보를 제공하는 이전대상기술 뷰 페이지 상세정보 > 패밀리정보 - 패밀리정보 표입니다.
순번 패밀리번호 국가코드 국가명 종류
1 US20160357612 US 미국 FAMILY

DOCDB 패밀리 정보

순번, 패밀리번호, 국가코드, 국가명, 종류의 정보를 제공하는 이전대상기술 뷰 페이지 상세정보 > 패밀리정보 - DOCDB 패밀리 정보 표입니다.
순번 패밀리번호 국가코드 국가명 종류
1 US2016357612 US 미국 DOCDBFAMILY
순번, 연구부처, 주관기관, 연구사업, 연구과제의 정보를 제공하는 이전대상기술 뷰 페이지 상세정보 > 국가R&D 연구정보 정보 표입니다.
순번 연구부처 주관기관 연구사업 연구과제
1 미래창조과학부 한국전자통신연구원 산업원천기술개발사업(SW컴퓨팅) 실시간 대규모 영상 데이터 이해 예측을 위한 고성능 비주얼 디스커버리 플랫폼 개발