| 1 |
1
데이터 스트림의 폭증을 처리하기 위한 데이터 스트림 처리 방법으로,데이터 스트림 처리 서비스를 수행하는 태스크들의 실행 상태 정보를 수집하는 제 1 단계;상기 태스크의 실행 상태 정보에 기초하여, 상기 서비스가 미리 정해진 처리 성능 조건을 만족하지 못한다고 판단되는 경우, 실행중인 태스크 중 상기 서비스의 처리 성능 저하의 원인이 되는 태스크를 판별하는 제 2 단계; 및상기 판별된 태스크로 입력되는 데이터 스트림을 분할하여 병렬 처리될 수 있도록 상기 서비스내의 태스크를 동적으로 재구성하는 제 3단계를 포함하고,상기 제 3 단계는,상기 판별된 태스크를 종료하고 소정의 수로 복제한 후, 분할 태스크를 생성하여 상기 복제된 태스크의 선행 태스크로 할당하고,상기 분할 태스크는 상기 판별된 태스크의 입력 데이터 스트림을 분할하여 상기 분할된 각 입력 데이터 스트림을 상기 복제된 태스크에 할당하는 태스크인, 데이터 스트림 처리 방법
|
| 2 |
2
제 1항에 있어서,상기 제 3 단계는, 상기 판별된 태스크의 실행 상태 정보에 기초하여 상기 판별된 태스크를 복제할 필요가 있다고 판단하는 경우에 수행되는, 데이터 스트림 처리 방법
|
| 3 |
3
제 1항에 있어서,상기 분할 태스크는 상기 판별된 태스크의 입력 데이터 스트림 소스별로 생성되고, 상기 소스별 입력 데이터 스트림을 상기 복제된 태스크의 수만큼 분할하는 것을 특징으로 하는 데이터 스트림 처리 방법
|
| 4 |
4
제 1항에 있어서,상기 제 3 단계는,상기 분할된 입력 데이터 스트림의 처리 결과인 출력 데이터 스트림들을 병합하는 병합 태스크를 동적으로 구축하여 상기 복제된 태스크들의 후행 태스크로 할당하는 단계를 더 포함하는 것을 특징으로 하는 데이터 스트림 처리 방법
|
| 5 |
5
제 4항에 있어서,상기 병합 태스크는 상기 판별된 태스크의 출력 데이터 스트림 소스별로 생성되며, 적어도 1개의 입력 데이터 스트림 소스로부터 입력되는 입력 데이터 스트림을 시간 순서에 맞추어 병합하여 1개의 데이터 스트림으로 출력하는 것을 특징으로 하는 데이터 스트림 처리 방법
|
| 6 |
6
제 1항에 있어서,상기 제 3 단계에서 동적으로 재 구성된 태스크들은 노드의 자원 사용 및 태스크의 처리 성능 정보를 바탕으로 다중 노드에 분산 할당되어 병렬 실행되는 것을 특징으로 하는 데이터 스트림 처리 방법
|
| 7 |
7
데이터 스트림의 폭증을 처리하기 위한 데이터 스트림 처리 장치로서,데이터 스트림 처리 서비스에 대한 요청에 따라 태스크를 할당하고 스케줄링하되, 상기 서비스가 미리 정해진 서비스 처리 성능 조건을 만족하지 못하는 경우, 실행중인 태스크 중 상기 서비스의 처리 성능 저하의 원인이 되는 태스크를 판별하고, 판별된 태스크로 입력되는 데이터 스트림을 분할하여 병렬 처리할 수 있도록 상기 서비스내의 태스크를 동적으로 재구성하는 서비스 관리부; 및상기 요청에 따른 태스크를 할당 받아 실행시키는 태스크 실행부를 포함하고,상기 서비스 관리부는,상기 판별된 태스크를 종료하고, 상기 판별된 태스크를 소정의 수로 복제한 후, 분할 태스크를 생성하여 상기 복제된 태스크의 선행 태스크로 할당하는 스케줄링 모듈을 포함하고,상기 분할 태스크는 상기 판별된 태스크의 입력 데이터 스트림을 분할하고 분할된 각 입력 데이터 스트림을 상기 복제된 태스크에 할당하는 태스크인, 데이터 스트림 처리 장치
|
| 8 |
8
제 7항에 있어서,상기 서비스 관리부는,상기 서비스에 대한 QoS(Quality of Service) 정보를 포함하는 요청 정보와 상기 서비스에 할당된 태스크 정보를 관리하는 서비스 관리 모듈; 및상기 서비스에 할당된 각 태스크에 대한 실행상태 정보를 수집하고, 상기 수집된 태스크들의 실행 상태 정보를 기초로, 상기 서비스가 상기 QoS(Quality of Service)의 처리 성능 임계치를 만족하지 못한다고 판단되는 경우, 상기 서비스의 처리 성능 저하의 원인이 되는 태스크를 판별하는 QoS 모니터링 모듈을 포함하고, 상기 스케줄링 모듈은, 상기 판별된 태스크의 실행 상태 정보에 기초하여, 상기 태스크를 복제할 필요가 있다고 판단하는 경우에 상기 판별된 태스크의 종료와 복제 및 상기 분할 태스크의 생성과 할당을 수행하는, 데이터 스트림 처리 장치
|
| 9 |
9
제 7항에 있어서,상기 분할 태스크는 상기 판별된 태스크의 입력 데이터 스트림 소스별로 생성되고, 상기 소스별 입력 데이터 스트림을 상기 복제된 태스크의 수만큼 분할하는태스크인 것을 특징으로 하는 데이터 스트림 처리 장치
|
| 10 |
10
제 8항에 있어서,상기 스케줄링 모듈은 상기 분할된 입력 데이터 스트림들의 처리 결과인 출력 데이터 스트림들을 병합하는 병합 태스크를 동적으로 구축하여 상기 복제된 태스크들의 후행 태스크로 할당하는 것을 특징으로 하는 데이터 스트림 처리 장치
|
| 11 |
11
제 10항에 있어서,상기 병합 태스크는 상기 판별된 태스크의 출력 데이터 스트림 소스별로 생성되며, 적어도 1개의 입력 데이터 스트림 소스로부터 입력되는 입력 데이터 스트림을 시간 순서에 맞추어 병합하여 1개의 데이터 스트림으로 출력하는 것을 특징으로 하는 데이터 스트림 처리 장치
|
| 12 |
12
제 7항에 있어서 상기 태스크 실행부는,상기 할당받은 태스크에 대하여 입력 데이터 스트림 소스 및 출력 데이터 스트림 소스를 바인딩하여 실행시키는 태스크 관리 모듈; 및상기 태스크 관리 모듈에 의해 실행중인 태스크의 실행 정보를 수집하여 상기 서비스 관리부로 전송하는 지역 모니터링 모듈을 포함하는 것을 특징으로 하는 데이터 스트림 처리 장치
|
