| 1 |
1
하나 이상의 스트림 컴포넌트를 포함하는 스트림 처리 프레임워크;사용자 인터페이스를 제공하고, 상기 사용자 인터페이스를 통해 상기 스트림 컴포넌트를 조합하는 입력을 받아 워크플로우 정보를 생성하는 사용자 인터페이스 제공부;워크플로우 정보를 WDL(Workflow Description Language) 정보로 변환하는 WDL 생성기; 및상기 WDL 정보를 해석하여 상기 스트림 처리 프레임워크를 통해 스트림 데이터를 수집 및 분석하는 워크플로우 실행부를 포함하는 스트림 분석 장치
|
| 2 |
2
제1 항에 있어서,상기 스트림 컴포넌트는 하나 이상의 메시지 큐를 통해 타 스트림 컴포넌트로 스트림 데이터를 전송하거나, 타 스트림 컴포넌트로부터 스트림 데이터를 수신하는 것을 특징으로 하는 스트림 분석 장치
|
| 3 |
3
제2항에 있어서, 상기 스트림 컴포넌트는 수집 컴포넌트, 스트림 처리 컴포넌트, 복합 이벤트 처리 컴포넌트, 저장 컴포넌트 중 어느 하나에 해당하는 것을 특징으로 하는 스트림 분석 장치
|
| 4 |
4
제3 항에 있어서,상기 수집 컴포넌트는,원격 데이터 소스로부터 상기 스트림 데이터를 수집하는 전송 에이전트;상기 전송 에이전트로부터 상기 스트림 데이터를 수신하는 타겟 에이전트; 및상기 스트림 데이터를 수신하여 상기 메시지 큐로 전송하는 출력 인터페이스;를 포함하는 것을 특징으로 하는 스트림 분석 장치
|
| 5 |
5
제4 항에 있어서,상기 타겟 에이전트는 상기 스트림 데이터에 대해 전처리 작업을 수행하는 것을 특징으로 하는 스트림 분석 장치
|
| 6 |
6
제3 항에 있어서,스트림 처리 컴포넌트는,상기 메시지 큐 중 입력 메시지 큐로부터 상기 스트림 데이터를 수신하는 입력 인터페이스;미리 설정된 패턴에 따라 상기 스트림 데이터를 분석하여 분석 데이터를 생성하는 데이터 분석부; 및상기 분석 데이터를 상기 메시지 큐 중 출력 메시지 큐로 전송하는 출력 인터페이스를 포함하는 것을 특징으로 하는 스트림 분석 장치
|
| 7 |
7
제3 항에 있어서,상기 복합 이벤트 처리 컴포넌트는,상기 메시지 큐 중 입력 메시지 큐로부터 상기 스트림 데이터를 수신하는 입력 인터페이스;상기 스트림 데이터 중 미리 정의된 조건에 만족하는 스트림 데이터를 선별하는 복합 이벤트 검출부;상기 미리 정의된 조건에 만족하는 스트림 데이터를 미리 지정된 패턴에 따라 분석하여 분석 데이터를 생성하는 데이터 분석부; 및상기 분석 데이터를 상기 메시지 큐 중 출력 메시지 큐로 전송하는 출력 인터페이스를 포함하는 것을 특징으로 하는 스트림 분석 장치
|
| 8 |
8
제3항에 있어서,상기 저장 컴포넌트는,상기 메시지 큐 중 입력 메시지 큐로부터 상기 스트림 데이터를 수신하는 입력 인터페이스;상기 스트림 데이터와 데이터베이스에 대응하는 스키마 매핑 정보를 저장하는 스키마 관리부; 및상기 스키마 매핑 정보를 참조하여 상기 데이터베이스 상에 상기 스트림 데이터를 저장하는 저장 관리부;를 포함하는 것을 특징으로 하는 스트림 분석 장치
|
| 9 |
9
사용자 인터페이스 제공부가, 사용자 인터페이스를 통해 사용자로부터 하나 이상의 스트림 컴포넌트를 조합하는 입력을 받는 단계;상기 사용자 인터페이스 제공부가, 상기 스트림 컴포넌트를 조합하는 입력에 따라 워크플로우 정보를 생성하는 단계;WDL(Workflow Description Language) 생성기가, 상기 워크플로우 정보를 WDL 정보로 변환하는 단계;워크플로우 실행부가, 상기 WDL 정보를 해석하여 상기 스트림 컴포넌트를 포함하는 스트림 처리 프레임워크를 통해 스트림 데이터를 수집 및 분석하는 단계를 포함하는 스트림 분석 방법
|
| 10 |
10
제9 항에 있어서,상기 스트림 컴포넌트는 하나 이상의 메시지 큐를 통해 타 스트림 컴포넌트로 스트림 데이터를 전송하거나, 타 스트림 컴포넌트로부터 스트림 데이터를 수신하는 것을 특징으로 하는 스트림 분석 방법
|
| 11 |
11
제10항에 있어서, 상기 스트림 컴포넌트는 수집 컴포넌트, 스트림 처리 컴포넌트, 복합 이벤트 처리 컴포넌트, 저장 컴포넌트 중 어느 하나에 해당하는 것을 특징으로 하는 스트림 분석 방법
|
| 12 |
12
제11 항에 있어서,상기 수집 컴포넌트는,원격 데이터 소스로부터 상기 스트림 데이터를 수집하는 전송 에이전트;상기 전송 에이전트로부터 상기 스트림 데이터를 수신하는 타겟 에이전트; 및상기 스트림 데이터를 수신하여 상기 메시지 큐로 전송하는 출력 인터페이스;를 포함하는 것을 특징으로 하는 스트림 분석 방법
|
| 13 |
13
제12 항에 있어서,상기 타겟 에이전트는 상기 스트림 데이터에 대해 전처리 작업을 수행하는 것을 특징으로 하는 스트림 분석 방법
|
| 14 |
14
제11 항에 있어서,스트림 처리 컴포넌트는,상기 메시지 큐 중 입력 메시지 큐로부터 상기 스트림 데이터를 수신하는 입력 인터페이스;미리 설정된 패턴에 따라 상기 스트림 데이터를 분석하여 분석 데이터를 생성하는 데이터 분석부; 및상기 분석 데이터를 상기 메시지 큐 중 출력 메시지 큐로 전송하는 출력 인터페이스를 포함하는 것을 특징으로 하는 스트림 분석 방법
|
| 15 |
15
제11 항에 있어서,상기 복합 이벤트 처리 컴포넌트는,상기 메시지 큐 중 입력 메시지 큐로부터 상기 스트림 데이터를 수신하는 입력 인터페이스;상기 스트림 데이터 중 미리 정의된 조건에 만족하는 스트림 데이터를 선별하는 복합 이벤트 검출부;상기 미리 정의된 조건에 만족하는 스트림 데이터를 미리 지정된 패턴에 따라 분석하여 분석 데이터를 생성하는 데이터 분석부; 및상기 분석 데이터를 상기 메시지 큐 중 출력 메시지 큐로 전송하는 출력 인터페이스를 포함하는 것을 특징으로 하는 스트림 분석 방법
|
| 16 |
16
제11항에 있어서,상기 저장 컴포넌트는,상기 메시지 큐 중 입력 메시지 큐로부터 상기 스트림 데이터를 수신하는 입력 인터페이스;상기 스트림 데이터와 데이터베이스에 대응하는 스키마 매핑 정보를 저장하는 스키마 관리부; 및상기 스키마 매핑 정보를 참조하여 상기 데이터베이스 상에 상기 스트림 데이터를 저장하는 저장 관리부;를 포함하는 것을 특징으로 하는 스트림 분석 방법
|
