| 1 |
1
입력되는 데이터 스트림에 대한 연속 처리 태스크의 병렬 처리에 대한 필요 여부를 판단하고 병렬 처리가 필요한 경우 데이터 스트림 분할 및 상기 데이터 스트림을 처리하기 위한 연속 처리 태스크를 다수의 분산처리 노드에 할당하여 처리할 것을 지시하는 제어 노드; 및상기 제어 노드의 지시에 따라 입력되는 상기 데이터 스트림을 분할하고 그 분할된 상기 데이터 스트림과 이를 처리하기 위한 연속 처리 태스크를 각각 할당하여 처리하고 그 처리한 결과를 통합하는 다수의 분산처리 노드를 포함하는 것을 특징으로 하는 분산 데이터 스트림 처리 시스템
|
| 2 |
2
제1 항에 있어서,상기 제어 노드는,일정한 데이터 스트림의 양에 대해 특정 연속 처리 태스크를 단일 노드에서 처리하는 비용과 다수의 노드에서 병렬 처리하는 비용을 비교하고 그 비교한 결과에 따라 태스크의 병렬 처리 여부를 판단하는 것을 특징으로 하는 분산 데이터 스트림 처리 시스템
|
| 3 |
3
제1 항에 있어서,상기 제어 노드는,다음의 수학식 을 만족하는 경우에 연속 처리 태스크의 병렬 처리가 필요하다고 판단하되, 여기서, W는 입력되는 데이터 스트림의 양을 나타내고, T1은 단일 노드의 데이터 전송 비용을 나타내며, C1은 단일 노드의 데이터 처리 비용을 나타내며, T2는 다수 노드들의 데이터 전송 비용을 나타내고, C2는 다수 노드들에서의 데이터 처리 비용을 나타내며, 및 M은 처리 결과를 통합하는 비용을 나타내는 것을 특징으로 하는 분산 데이터 스트림 처리 시스템
|
| 4 |
4
데이터 스트림을 입력 받거나 상기 데이터 스트림에 대한 처리 결과를 송신하는 송수신부;입력받는 상기 데이터 스트림에 대한 연속 처리 태스크의 병렬 처리 여부에 따라 상기 데이터 스트림을 분할하는 분할부; 및그 분할된 상기 데이터 스트림과 이를 처리하기 위한 연속 처리 태스크의 병렬 태스크를 다수의 분산처리 노드에 할당하여 처리하는 처리부를 포함하는 것을 특징으로 하는 연속 처리 태스크를 병렬 처리하기 위한 장치
|
| 5 |
5
제4 항에 있어서,상기 연속 처리 태스크의 병렬 처리 여부는,일정한 데이터 스트림의 양에 대해 특정 연속 처리 태스크를 단일 노드에서 처리하는 비용과 다수의 노드에서 병렬 처리하는 비용을 비교하고 그 비교한 결과에 따라 판단하는 것을 특징으로 하는 연속 처리 태스크를 병렬 처리하기 위한 장치
|
| 6 |
6
제4 항에 있어서,상기 연속 처리 태스크의 병렬 처리 여부는,다음의 수학식 을 만족하는 경우에 필요하다고 판단하되, 여기서, W는 입력되는 데이터 스트림의 양을 나타내고, T1은 단일 노드의 데이터 전송 비용을 나타내며, C1은 단일 노드의 데이터 처리 비용을 나타내며, T2는 다수 노드들의 데이터 전송 비용을 나타내고, C2는 다수 노드들에서의 데이터 처리 비용을 나타내며, 및 M은 처리 결과를 통합하는 비용을 나타내는 것을 특징으로 하는 연속 처리 태스크를 병렬 처리하기 위한 장치
|
| 7 |
7
제4 항에 있어서,상기 분할부는,상기 데이터 스트림을 데이터 스트림의 최소 단위인 레코드나 연속 처리 태스크 처리의 기본 단위인 윈도우를 기준으로 분할하는 것을 특징으로 하는 연속 처리 태스크를 병렬 처리하기 위한 장치
|
| 8 |
8
제4 항에 있어서,상기 분할부는,다수의 입력 소스로부터 입력되는 데이터 스트림을 통합한 후에 분할하거나, 입력되는 상기 데이터 스트림을 각각 분할하는 것을 특징으로 하는 연속 처리 태스크를 병렬 처리하기 위한 장치
|
| 9 |
9
제4 항에 있어서,상기 처리부는,상기 다수의 분산처리 노드에 연속 처리 태스크의 병렬 태스크를 미리 분산 배치한 후에 분할된 상기 데이터 스트림을 각 분산처리 노드의 병렬 태스크에 전달하여 처리하거나,분할된 상기 데이터 스트림을 다수의 분산처리 노드에 분산 저장한 후에 각 분산처리 노드에 연속 처리 태스크의 병렬 태스크를 배치하여 처리하는 것을 특징으로 하는 연속 처리 태스크를 병렬 처리하기 위한 장치
|
| 10 |
10
제9 항에 있어서,상기 처리부는,상기 데이터 스트림을 입력되는 순서대로 연속 처리 태스크에 할당하거나, 입력되는 순서와 상관없이 연속 처리 태스크에 할당하는 것을 특징으로 하는 연속 처리 태스크를 병렬 처리하기 위한 장치
|
| 11 |
11
제4 항에 있어서,상기 다수의 분산처리 노드로부터 연속 처리 태스크의 병렬처리 결과를 제공받아 제공받은 상기 연속 처리 태스크의 병렬처리 결과를 사용자에게 전달하거나 다음 연속 처리 태스크의 입력으로 전달하는 통합부를 더 포함하는 것을 특징으로 하는 연속 처리 태스크를 병렬 처리하기 위한 장치
|
| 12 |
12
(a) 입력되는 데이터 스트림에 대한 연속 처리 태스크의 병렬 처리에 대한 필요 여부를 판단하는 단계;(b) 그 판단한 결과에 따라 상기 데이터 스트림을 분할하는 단계; 및(c) 그 분할된 상기 데이터 스트림과 이를 처리하기 위한 연속 처리 태스크의 병렬 태스크를 다수의 분산처리 노드에 각각 할당하여 처리하는 단계를 포함하는 것을 특징으로 하는 연속 처리 태스크를 병렬 처리하기 위한 방법
|
| 13 |
13
제12 항에 있어서,상기 (a) 단계는,일정한 데이터 스트림의 양에 대해 특정 연속 처리 태스크를 단일 노드에서 처리하는 비용과 다수의 노드에서 병렬 처리하는 비용을 비교하고 그 비교한 결과에 따라 연속 처리 태스크의 병렬 처리 여부를 판단하는 것을 특징으로 하는 연속 처리 태스크를 병렬 처리하기 위한 방법
|
| 14 |
14
제12 항에 있어서,상기 (a) 단계는,다음의 수학식 을 만족하는 경우에 연속 처리 태스크의 병렬 처리가 필요하다고 판단하되, 여기서, W는 입력되는 데이터 스트림의 양을 나타내고, T1은 단일 노드의 데이터 전송 비용을 나타내며, C1은 단일 노드의 데이터 처리 비용을 나타내며, T2는 다수 노드들의 데이터 전송 비용을 나타내고, C2는 다수 노드들에서의 데이터 처리 비용을 나타내며, 및 M은 처리 결과를 통합하는 비용을 나타내는 것을 특징으로 하는 연속 처리 태스크를 병렬 처리하기 위한 방법
|
| 15 |
15
제12 항에 있어서,상기 (b) 단계는,상기 데이터 스트림을 데이터 스트림의 최소 단위인 레코드나 태스크 처리의 기본 단위인 윈도우를 기준으로 분할하는 것을 특징으로 하는 연속 처리 태스크를 병렬 처리하기 위한 방법
|
| 16 |
16
제12 항에 있어서,상기 (b) 단계는,다수의 입력 소스로부터 입력되는 데이터 스트림을 통합한 후에 분할하거나, 입력되는 상기 데이터 스트림을 각각 분할하는 것을 특징으로 하는 연속 처리 태스크를 병렬 처리하기 위한 방법
|
| 17 |
17
제12 항에 있어서,상기 (c) 단계는,상기 다수의 분산처리 노드에 연속 처리 태스크의 병렬 태스크를 미리 분산 배치한 후에 분할된 상기 데이터 스트림을 각 분산처리 노드의 병렬 태스크에 전달하여 처리하거나,분할된 상기 데이터 스트림을 다수의 분산처리 노드에 분산 할당한 후에 각 분산처리 노드에 연속 처리 태스크의 병렬 태스크를 배치하는 것을 특징으로 하는 연속 처리 태스크를 병렬 처리하기 위한 방법
|
| 18 |
18
제17 항에 있어서,상기 (c) 단계는,상기 데이터 스트림을 입력되는 순서대로 병렬 태스크에 전달하거나, 입력되는 순서와 상관없이 병렬 태스크에 전달하는 것을 특징으로 하는 연속 처리 태스크를 병렬 처리하기 위한 방법
|
