| 1 |
1
네트워크 내 무작위로 분산되어 소정의 상태를 모니터링하여 스트림 센서 데이터를 출력하는 센서 노드와,다수의 센서 노드와 교신하며, 상기 네트워크 내 다수의 이벤트를 저장 및 통합 관리하는 서버 노드와,상기 서버 노드와 연동되어 서버 노드로부터 전송되는 데이터를 하둡(Hadoop)에서 맵리듀스(MapReduce)에 따라 기설정된 단위의 저장 영역으로 분산하여 저장하는 하둡 분산 파일 시스템(Hadoop Distributed File System: HDFS)부를 포함하고,상기 서버 노드는,상기 센서 노드별 수집된 스트림 센서 로(raw) 데이터를 파싱하여 하둡에서 맵리듀스에 기반한 데이터의 분산 병렬처리를 보장하기 위한 데이터로 변환하는 데이터 어댑터 레이어부와,상기 데이터 어댑터 레이어부를 통하여 전달된 센서 노드별 스트림 센서 데이터를 서버 노드 내에서 중계 및 상기 HDFS부에 저장 요청하는 데이터 수집 레이어부와,사용자로부터 기등록된 질의를 관리하고, 질의가 주어지면 해당 질의를 분석하여 연속질의 인덱스를 생성하고, 상기 스트림 센서 데이터를 수신하여 질의를 처리하는 데이터 처리 레이어부를 포함함을 특징으로 하는 하둡 기반 센서 스트림 데이터 처리 시스템
|
| 2 |
2
제1항에 있어서, 상기 서버 노드는,상기 센서 노드별 발생하는 스트림 센서 데이터를 기설정된 주기별로 수집하는 데이터 수집부와,상기 데이터 수집부로부터 수집된 스트림 센서 데이터에 대한 파일 볼륨을 분할하여 상기 HDFS부에 저장하기 위한 파일 블록들로 구성된 청크(chunk)를 생성하는 청크 생성부와,상기 청크 생성부로부터 생성된 청크를 상기 HDFS부에 저장 요청하고, 해당 청크의 저장 결과를 수신하는 청크 처리 요청부를 포함함을 특징으로 하는 하둡 기반 센서 스트림 데이터 처리 시스템
|
| 3 |
3
삭제
|
| 4 |
4
제1항에 있어서, 상기 데이터 처리 레이어부는,네트워크를 통해 연동된 하둡 분산 파일 시스템(Hadoop Distributed File System: HDFS)부로부터 기저장된 스트림 센서 데이터의 이력정보를 수신하고, 상기 이력정보를 기반으로 통계분석 알고리즘을 적용하여 분석된 스트림 센서 데이터에 대응하는 맵리듀스 모델링을 생성하고 이를 실시간 스트림 센서 데이터와 결합하여 상기 HDFS부로 전송하는 이력 데이터 처리부를 포함함을 특징으로 하는 하둡 기반 센서 스트림 데이터 처리 시스템
|
| 5 |
5
제1항에 있어서, 상기 서버 노드는,서버 노드 내의 전반적인 동작을 제어하며, 센서 노드 수, 스트림 센서 데이터 기설정된 주기, 스트림 센서 데이터 크기 및 네트워크 내 센서 허브 수를 인자로 하여 수집된 스트림 센서 데이터 크기를 연산하고, 연산 결과를 기정의된 스트림 센서 데이터와 비교하여 상기 기정의된 스트림 센서 데이터와 동일한 경우 데이터 처리 레이어부로 출력하고, 동일하지 않은 경우 기설정된 스트림 센서 데이터 수집 대기 시간 내에서 상기 기정의된 스트림 센서 데이터와의 비교 연산을 수행하도록 제어하는 제어부를 더 포함함을 특징으로 하는 하둡 기반 센서 스트림 데이터 처리 시스템
|
| 6 |
6
제1항에 있어서, 상기 데이터 처리 레이어부는,질의 처리 시 연속적으로 수집되는 스트림 센서 데이터에서 특정 컬럼 검색을 위한 에이브이엘(AVL) 트리를 적용하여 제1단계 인덱스를 제공하고,상기 제1단계 인덱스를 기반한 통계정보를 계산하고, R-Tree를 이용하여 제2단계 인덱스를 제공함을 특징으로 하는 하둡 기반 센서 스트림 데이터 처리 시스템
|
| 7 |
7
다수의 센서 노드를 통합 괸리하는 서버 노드에서 센서 노드별 발생하는 스트림 센서 데이터를 기설정된 주기별로 수집하는 과정과,수집된 상기 스트림 센서 데이터에 대한 파일 볼륨을 분할하여 네트워크를 통해 연동된 하둡 분산 파일 시스템(Hadoop Distributed File System: HDFS)부에 저장하기 위한 파일 블록들로 구성된 청크(chunk)를 생성하는 과정과,생성된 상기 청크를 상기 HDFS부에 저장 요청하고, 해당 청크의 저장 결과를 수신하는 과정과,상기 서버 노드와 연동되어 서버 노드로부터 전송되는 데이터를 하둡에서 맵리듀스에 따라 기설정된 단위의 저장 영역으로 분산하여 저장하는 과정을 포함하고,상기 센서 노드별 수집된 스트림 센서 로(raw) 데이터를 파싱하여 하둡에서 맵리듀스에 기반한 데이터의 분산 병렬처리를 보장하기 위한 데이터로 변환하는 과정과,사용자로부터 질의가 주어지면 해당 질의를 분석하여 연속질의 인덱스를 생성하고, 상기 스트림 센서 데이터를 수신하여 질의를 처리하는 과정을 더 포함함을 특징으로 하는 하둡 기반 센서 스트림 데이터 처리 방법
|
| 8 |
8
삭제
|
| 9 |
9
제7항에 있어서, 네트워크를 통해 연동된 하둡 분산 파일 시스템(Hadoop Distributed File System: HDFS)부로부터 기저장된 스트림 센서 데이터의 이력정보를 수신하는 과정과,상기 이력정보를 기반으로 통계분석 알고리즘을 적용하여 분석된 스트림 센서 데이터에 대응하는 맵리듀스 모델링을 생성하는 과정과,생성된 맵리듀스 모델링을 실시간 스트림 센서 데이터와 결합하여 상기 HDFS부로 전송하는 과정을 더 포함함을 특징으로 하는 하둡 기반 센서 스트림 데이터 처리 방법
|
| 10 |
10
제7항에 있어서, 상기 서버 노드는,서버 노드 내의 전반적인 동작을 제어하며, 센서 노드 수, 스트림 센서 데이터 기설정된 주기, 스트림 센서 데이터 크기 및 네트워크 내 센서 허브 수를 인자로 하여 수집된 스트림 센서 데이터 크기를 연산하고, 연산 결과를 기정의된 스트림 센서 데이터와 비교하여 상기 기정의된 스트림 센서 데이터와 동일한 경우 데이터 처리 레이어부로 출력하고, 동일하지 않은 경우 기설정된 스트림 센서 데이터 수집 대기 시간 내에서 상기 기정의된 스트림 센서 데이터와의 비교 연산을 수행하도록 제어함을 특징으로 하는 하둡 기반 센서 스트림 데이터 처리 방법
|
