Newer
Older
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
---
html:
toc: true
offline: true
export_on_save:
html: true
---
# Component List (v19.03)
---
KSB 인공지능 프레임워크가 기본적으로 제공하는 컴포넌트의 목록입니다.
## Reader
###ksb.csle.component.reader
| 컴포넌트 이름 | 구현 클래스명 | 설명 |
|-------------|-------------|------------|
| FileReader | ksb.csle.component.reader.<br>FileReader | 파일 입력기 | |
| HttpClientReader |ksb.csle.component.reader.<br>HttpClientReader |HTTP 클라이언트 기반 데이터 입력기 | |
| HttpServerReader |ksb.csle.component.reader.<br>HttpServerReader |HTTP 서버 기반 데이터 입력기 | |
| HttpWeatherClientReader |ksb.csle.component.reader.<br>HttpWeatherClientReader |HTTP 클라이언트 기반 동네기상 데이터 입력기 | |
| KafkaOnDemandReader |ksb.csle.component.reader.<br>KafkaOnDemandReader | Kafka 데이터 입력기 | |
| KafkaReader |ksb.csle.component.reader.<br>KafkaReader | Kafka용 데이터 입력기 | |
| MongodbReader |ksb.csle.component.reader.<br>MongodbReader |Mongodb 데이터 입력기 | |
| MultipleReaders |ksb.csle.component.reader.<br>MultipleReaders |다중입력기 | |
| Onem2mHttpReader |ksb.csle.component.reader.<br>Onem2mHttpReader |OneM2M 데이터 입력기 | |
| PhoenixReader |ksb.csle.component.reader.<br>PhoenixReader |Phoenix 기반의 HBase 데이터 입력기 | |
| TableReader |ksb.csle.component.reader.<br>TableReader |JDBC 기반 데이터 입력기 | |
###ksb.csle.component.pipe.stream.reader
| 컴포넌트 이름 | 구현 클래스명 | 설명 |
|-------------|-------------|------------|
| FilePipeReader |ksb.csle.component.pipe.stream.reader.<br>FilePipeReader | 스트림 처리용 파일 입력기 | |
| KafkaContextQueryPipeReader | ksb.csle.component.pipe.stream.reader.<br>KafkaContextQueryPipeReader | Kafka 토픽 쿼리 파이프라인 입력기 | |
| KafkaPipeReader | ksb.csle.component.pipe.stream.reader.<br>KafkaPipeReader |카프카 스트림 입력기 | |
<br>
## writer
###ksb.csle.component.writer
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|FileWriter |ksb.csle.component.writer.<br>FileWriter |파일 출력기| |
|HttpClientWriter | ksb.csle.component.writer.<br>HttpClientWriter | HTTP 클라이언트 기반 데이터 출력기 | |
|KafkaWriter |ksb.csle.component.writer.<br>KafkaWriter | Kafka 데이터 출력기 | |
|MongodbWriter |ksb.csle.component.writer.<br>MongodbWriter |Mongodb 데이터 출력기| |
|PhoenixWriter |ksb.csle.component.writer.<br>PhoenixWriter |Phoenix 기반의 HBase 데이터 출력기| |
|StdoutWriter |ksb.csle.component.writer.<br>StdoutWriter |표준출력(콘솔화면) 데이터 출력기| |
|TableWriter |ksb.csle.component.writer.<br>TableWriter |JDBC 기반 데이터 출력기 | |
###ksb.csle.component.pipe.stream.writer
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|ConsolePipeWriter |ksb.csle.component.pipe.stream.writer.<br>ConsolePipeWriter |콘솔 스트림 출력기 | |
|FilePipeWriter |ksb.csle.component.pipe.stream.writer.<br>FilePipeWriter |파일 스트림 출력기 | |
|HBasePipeWriter |ksb.csle.component.pipe.stream.writer.<br>HBasePipeWriter |HBase 스트림 출력기| |
|KafkaPipeWriter|ksb.csle.component.pipe.stream.writer.<br>KafkaPipeWriter |카프카 스트림 출력기 | |
|MemoryPipeWriter| ksb.csle.component.pipe.stream.writer.<br>MemoryPipeWriter |스트림 출력기 | |
<br>
## Operator
###ksb.csle.component.operator.analysis
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|DLTrainOperator |ksb.csle.component.operator.analysis.<br>DLTrainOperator |텐서플로우 딥러닝 학습용 처리기 | |
|RandomForestClassifierPredictOperator |ksb.csle.component.operator.analysis.<br>RandomForestClassifierPredictOperator |RandomForest 분류 모델을 이용하여 label 예측 | |
|RandomForestClassifierTrainOperator |ksb.csle.component.operator.analysis.<br>RandomForestClassifierTrainOperator |RandomForest 분류 모델 생성 | |
|SparkMLPredictOperator |ksb.csle.component.operator.analysis.<br>SparkMLPredictOperator |SparkML 예측 처리기 | |
|TensorflowPredictOperator |ksb.csle.component.operator.analysis.<br>TensorflowPredictOperator |텐서플로우 예측용 오퍼레이터 | |
|AutoSparkMLOperator| -| 기계학습모델 자동학습기| |
|DecisionTreeClassifier | - |Decision Tree Classifier 학습기 | |
|DecisionTreeRegressor | - |Decision Tree Regressor 학습기 | |
|LinearRegressionRegressor | - |Linear Regression Regressor 학습기 | |
|NaiveBayesClassifier | - |Naive Bayes Classifier 학습기 | |
|RandomForestClassifier | - |Random Forests Classifier 학습기 | |
|RandomForestRegressor | - |Random Forests Regressor 학습기 | |
### ksb.csle.component.operator.cleaning
|컴포넌트 이름 | 구현 클래스명 | 설명 | 관련 링크|
|---|---|---|---|
|AgglomerativeClusteringOperator |ksb.csle.component.operator.cleaning.<br>AgglomerativeClusteringOperator |Agglomerative 클러스터링 처리기 |<a href="./operator/4.1.1.8.AgglomerativeClustering_manual.html" > Link</a> |
|DBScanOperator |ksb.csle.component.operator.cleaning.<br>DBScanOperator |DBSCAN 클러스터링 처리기 | <a href="./operator/4.1.1.1.DBSCAN_manual.html"> Link </a> |
|EMClusteringOperator |ksb.csle.component.operator.cleaning.<br>EMClusteringOperator |EM 클러스터링 처리기 | <a href="./operator/4.1.1.2.EMClustering_manual.html">Link</a> |
|EqualDepthBinningOperator |ksb.csle.component.operator.cleaning.<br>EqualDepthBinningOperator |동일 빈도수 이산화 처리기 |<a href="./operator/4.1.1.3.EqualDepthBinning_manual.html" > Link</a> |
|EqualWidthBinningOperator |ksb.csle.component.operator.cleaning.<br>EqualWidthBinningOperator |동일 폭 이산화 처리기 | <a href="./operator/4.1.1.6.EqualWidthBinning_manual.html" > Link</a> |
|GeneralizedLinearRegressionOperator |ksb.csle.component.operator.cleaning.<br>GeneralizedLinearRegressionOperator |Generalized Linear Regression 처리기 | <a href="./operator/4.1.1.9.GeneralizedLinearRegression_manual.html" > Link</a> |
|KMeansOperator |ksb.csle.component.operator.cleaning.<br>KMeansOperator |Kmeans 클러스터링 처리기 | <a href="./operator/4.1.1.4.KMeans_manual.html" > Link</a> |
|KMedoidsOperator |ksb.csle.component.operator.cleaning.<br>KMedoidsOperator |KMedoids 클러스터링 처리기 | <a href="./operator/4.1.1.5.KMedoids_manual.html" > Link</a>
|LinearRegressionOperator |ksb.csle.component.operator.cleaning.<br>LinearRegressionOperator |Linear Regression 처리기 | <a href="./operator/4.1.1.7.LinearRegression_manual.html" > Link</a> |
|MissingValueImputeOperator |ksb.csle.component.operator.cleaning.<br>MissingValueImputeOperator |데이터 공백 처리기 |<a href="./operator/4.1.1.10.MissingValueImpute_manual.html" > Link</a> |
###ksb.csle.component.operator.integration
|컴포넌트 이름 | 구현 클래스명 | 설명 | 관련 링크|
|---|---|---|---|
|ConcatAndReshapeOperator |ksb.csle.component.operator.integration.<br>ConcatAndReshapeOperator |다수의 column을 조합하여 새로운 column 생성기| <a href="./operator/4.1.1.11.ConcatAndReshape_manual.html" > Link</a> |
|GroupByOperator |ksb.csle.component.operator.integration.<br>GroupByOperator |특정 조건에 따른 해당 column의 grouping 처리기 | <a href="./operator/4.1.1.12.GroupBy_manual.html" > Link</a> |
|OrderByOperator |ksb.csle.component.operator.integration.<br>OrderByOperator |오름차순, 내림차순에 따라 row 정렬 처리기 | <a href="./operator/4.1.1.13.OrderBy_manual.html" > Link</a> |
|TimeIndexAddOperator |ksb.csle.component.operator.integration.<br>TimeIndexAddOperator |Unix timestamp column 삽입 처리기 | <a href="./operator/4.1.1.14.TimeIndexAdd_manual.html" > Link</a> |
|VectorAssembleColumnAddOperator |ksb.csle.component.operator.integration.<br>VectorAssembleColumnAddOperator |Spark ML 동작을 위한 Vector assemble 처리기 | |
###ksb.csle.component.operator.reduction
|컴포넌트 이름 | 구현 클래스명 | 설명 | 관련 링크|
|---|---|---|---|
|AggregateOperator |ksb.csle.component.operator.reduction.<br>AggregateOperator |숫자형 데이터 통계값 (min, max, avg, std, count) 대체 |<a href="./operator/4.1.1.16.Aggregate_manual.html" > Link</a> |
|ChiSquareSelectOperator |ksb.csle.component.operator.reduction.<br>ChiSquareSelectOperator |Chi-Square test를 이용한 column 선택처리기 |<a href="./operator/4.1.1.17.ChiSquareSelect_manual.html" > Link</a> |
|ColumnRemoveOperator |ksb.csle.component.operator.reduction.<br>ColumnRemoveOperator |선택한 column들 삭제 처리기 | <a href="./operator/4.1.1.18.ColumnRemove_manual.html" > Link</a> |
|ColumnSelectOperator |ksb.csle.component.operator.reduction.<br>ColumnSelectOperator |column 선택 및 재배열 처리기 |<a href="./operator/4.1.1.19.ColumnSelect_manual.html" > Link</a> |
|ColumnSelectWithFileOperator |ksb.csle.component.operator.reduction.<br>ColumnSelectWithFileOperator |파일로부터 칼럼 선택 및 재배열 처리기 | |
|DecisionTreeInductOperator |ksb.csle.component.operator.reduction.<br>DecisionTreeInductOperator |Decision Tree Induction을 이용한 column 선택처리기 |<a href="./operator/4.1.1.20.DecisionTreeInduct_manual.html" > Link</a> |
|FilterOperator |ksb.csle.component.operator.reduction.<br>FilterOperator |특정 조건에 따른 row 필터 처리기 |<a href="./operator/4.1.1.21.Filter_manual.html" > Link</a> |
|FilterUsingSqlOperator |ksb.csle.component.operator.reduction.<br>FilterUsingSqlOperator |SQL을 이용한 row 필터 처리기 |<a href="./operator/4.1.1.22.FilterUsingSql_manual.html" > Link</a> |
|GroupByFilterOperator |ksb.csle.component.operator.reduction.<br>GroupByFilterOperator |총계처리 후 필터링 | |
|OrderByFilterOperator |ksb.csle.component.operator.reduction.<br>OrderByFilterOperator |정렬 후 필터링 | |
|PCAOperator |ksb.csle.component.operator.reduction.<br>PCAOperator |PCA를 이용한 column 생성 처리기 | <a href="./operator/4.1.1.23.PCA_manual.html" > Link</a> |
|RandomSamplingOperator |ksb.csle.component.operator.reduction.<br>RandomSamplingOperator |단순 무작위 표본 추출 처리기 | <a href="./operator/4.1.1.24.RandomSampling_manual.html" > Link</a> |
|StepwiseBackwardEliminateOperator |ksb.csle.component.operator.reduction.<br>StepwiseBackwardEliminateOperator |Stepwise Backward Elimination를 이용한 column 선택처리기 |<a href="./operator/4.1.1.25.StepwiseBackwardEliminate_manual.html" > Link</a> |
|StepwiseForwardSelectOperator |ksb.csle.component.operator.reduction.<br>StepwiseForwardSelectOperator |Stepwise Forward Selection를 이용한 column 선택처리기 | <a href="./operator/4.1.1.26.StepwiseForwardSelect_manual.html" > Link</a> |
|StratifiedSamplingOperator |ksb.csle.component.operator.reduction.<br>StratifiedSamplingOperator |계층화된 샘플에서 표본 추출 처리기 | <a href="./operator/4.1.1.27.StratifiedSampling_manual.html" > Link</a> |
|TimeWindowAggregateOperator |ksb.csle.component.operator.reduction.<br>TimeWindowAggregateOperator |Unit timestamp 정보를 이용하여 시간정보에 따라 aggregation 처리기 | |
###ksb.csle.component.operator.service
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|ControlContextQueryOperator |ksb.csle.component.operator.service.<br>ControlContextQueryOperator |컨텍스트 및 제어 쿼리 처리기 | |
|TensorflowServingOperator |ksb.csle.component.operator.service.<br>TensorflowServingOperator |텐서플로우 모델 예측 처리기 | |
|WeatherQueryOperator |ksb.csle.component.operator.service.<br>WeatherQueryOperator |지식베이스 엔진 쿼리 처리기 | |
###ksb.csle.component.operator.transformation
|컴포넌트 이름 | 구현 클래스명 | 설명 | 관련 링크|
|---|---|---|---|
|AddConditionalColumnOperator |ksb.csle.component.operator.transformation.<br>AddConditionalColumnOperator |주어진 조건에 의해 새로운 column 생성 | |
|ChangeColumnDataTypeOperator |ksb.csle.component.operator.transformation.<br>ChangeColumnDataTypeOperator |column의 데이터 타입 변경 | |
|ExplodeColumnOperator |ksb.csle.component.operator.transformation.<br>ExplodeColumnOperator |array/map 타입 column의 각 element로부터 새로운 row 생성 | |
|FlattenOperator |ksb.csle.component.operator.transformation.<br>FlattenOperator |선택한 column의 모든 row을 하나의 row로 합치는 처리기 | |
|InterpolateOperator |ksb.csle.component.operator.transformation.<br>InterpolateOperator |일정한 간격으로 데이터를 보간하여 새로운 데이터프레임 생성 |<a href="./operator/4.1.1.29.Interpolate_manual.html" > Link</a> |
|MinMaxScalingOperator |ksb.csle.component.operator.transformation.<br>MinMaxScalingOperator |최소/최대값을 기준으로 스케일링 처리기 | <a href="./operator/4.1.1.30.MinMaxScaling_manual.html" > Link</a> |
|NullReplaceOperator |ksb.csle.component.operator.transformation.<br>NullReplaceOperator |공백문자나 Zero 값 Null 대체기 | |
|OneHotEncodingOperator |ksb.csle.component.operator.transformation.<br>OneHotEncodingOperator |One-Hot-Encoding 처리기 | <a href="./operator/4.1.1.32.OneHotEncoding_manual.html" > Link</a> |
|PivotOperator |ksb.csle.component.operator.transformation.<br>PivotOperator | 특정 column 내 값을 row의 schema 정보로 변환 처리기 |<a href="./operator/4.1.1.33.Pivot_manual.html" > Link</a> |
|RenameColumnOperator |ksb.csle.component.operator.transformation.<br>RenameColumnOperator |column 이름 변경 | | |
|ReshapeWithTimeWindowOperator |ksb.csle.component.operator.transformation.<br>ReshapeWithTimeWindowOperator |Time window 값에 따라 shift된 row 생성 처리기 ||
|SelectWithTimeWindowOperator |ksb.csle.component.operator.transformation.<br>SelectWithTimeWindowOperator |Time window 값에 따라 shift된 row 선택 처리기 |<a href="./operator/4.1.1.35.SelectWithTimeWindow_manual.html" > Link</a> |
|SplitColumnOperator |ksb.csle.component.operator.transformation.<br>SplitColumnOperator |array/map 타입 column의 element를 각 column으로 분리 | |
|StringIndexOperator |ksb.csle.component.operator.transformation.<br>StringIndexOperator |문자열 타입의 컬럼에 대한 색인 컬럼을 생성 | |
|TimeSynchronizeOperator |ksb.csle.component.operator.transformation.<br>TimeSynchronizeOperator |시간(timestamp)을 동기화하여 두 개의 데이터프레임 join | |
|TransposeOperator |ksb.csle.component.operator.transformation.<br>TransposeOperator |하나의 dataframe column을 row로 변환 처리기|<a href="./operator/4.1.1.37.Transpose_manual.html" > Link</a> |
|VectorizeColumnOperator |ksb.csle.component.operator.transformation.<br>VectorizeColumnOperator |여러 column들을 모아서 하나의 vector 타입 column을 생성 | |
###ksb.csle.component.pipe.query.operator
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|KafkaContextQueryPipeOperator |ksb.csle.component.pipe.query.operator.<br>KafkaContextQueryPipeOperator |카프카 OnDemand 쿼리용 | |
|OutputAggregatePipeOperator |ksb.csle.component.pipe.query.operator.<br>OutputAggregatePipeOperator |하나 이상의 질의결과를 축약하는 축약 오퍼레이터 | |
|OutputCumulativePipeOperator |ksb.csle.component.pipe.query.operator.<br>OutputCumulativePipeOperator |질의를 수행하고 전달되는 결과를 append하여 전달하는 질의 오퍼레이터 | |
|OutputRestfulContextQueryPipeOperator |ksb.csle.component.pipe.query.operator.<br>OutputRestfulContextQueryPipeOperator |질의를 수행하고 전달되는 결과를 단순전달하는 질의 오퍼레이터 | |
|RouteMappingPipeOperator |ksb.csle.component.pipe.query.operator.<br>RouteMappingPipeOperator |매핑 기반 경로 변환 오퍼레이터 | |
|RouteRestfulContextQueryPipeOperator |ksb.csle.component.pipe.query.operator.<br>RouteRestfulContextQueryPipeOperator |쿼리 기반 경로 컨텍스트 변환 오퍼레이터 | |
###ksb.csle.component.pipe.stream.operator
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|FilterOperator |ksb.csle.component.pipe.stream.operator.<br>FilterOperator |스트림 파이프라인용 필터 | |
|GroupByOperator |ksb.csle.component.pipe.stream.operator.<br>GroupByOperator |스트림 파이프라인용 그룹 처리기 | |
|OrderByOperator |ksb.csle.component.pipe.stream.operator.<br>OrderByOperator |스트림 파이프라인용 row 정렬 처리기 | |
|RenameColumnsPipeOperator |ksb.csle.component.pipe.stream.operator.<br>RenameColumnsPipeOperator |칼럼 이름 및 타입 변경 오퍼레이터 | |
|SelectColumnsPipeOperator |ksb.csle.component.pipe.stream.operator.<br>SelectColumnsPipeOperator |스트림 파이프라인용 칼럼 선택기 | |
|SparkMLPredictPipeOperator |ksb.csle.component.pipe.stream.operator.<br>SparkMLPredictPipeOperator | Pipeline기반 ML prediction용 operator | |
|StreamAllJoinOperator |ksb.csle.component.pipe.stream.operator.<br>StreamAllJoinOperator |스트림 key기반 칼럼결합기 | |
|StreamJoinOperator |ksb.csle.component.pipe.stream.operator.<br>StreamJoinOperator | 두 개 이상의 입력데이터로부터 같은 keyword의 데이터 결합| |
|StreamTimeJoinOperator |ksb.csle.component.pipe.stream.operator.<br>StreamTimeJoinOperator |스트림 방식의 시간 조인 파이프라인 오퍼레이터 | |
###ksb.csle.didentification.privacy
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|AggregationOperator |ksb.csle.didentification.privacy.<br>AggregationOperator |선택한 column들에 대한 aggregation 처리기 | |
|BlankImputeOperator |ksb.csle.didentification.privacy.<br>BlankImputeOperator |특정 위치에 공백 및 별표 처리 | |
|DataRangeOperator |ksb.csle.didentification.privacy.<br>DataRangeOperator |사용자 입력 기반 범주화 처리 | |
|EncryptionOperator |ksb.csle.didentification.privacy.<br>EncryptionOperator |SHA-1기반 암호화기 | |
|HeuristicOperator | ksb.csle.didentification.privacy.<br>HeuristicOperator |랜덤 스트링 기반 가명 처리기 | |
|HidingOperator |ksb.csle.didentification.privacy.<br>HidingOperator |문자열 데이터 통계값(최빈문자열 또는 ....) 대체 | |
|IdenReductionOperator |ksb.csle.didentification.privacy.<br>IdenReductionOperator |식별자 제거기 | |
|PartialAggregateOperator | ksb.csle.didentification.privacy.<br>PartialAggregateOperator |outlier값 갖는 cell 통계값 대체 | |
|PartialIdenReductionOperator |ksb.csle.didentification.privacy.<br>PartialIdenReductionOperator |식별자 중 ouliter값을 갖는 cell 값 대체 | |
|QuasiReductionOperator |ksb.csle.didentification.privacy.<br>QuasiReductionOperator |준식별자 제거 | |
|RandomNoiseOperator |ksb.csle.didentification.privacy.<br>RandomNoiseOperator |특정 위치에 잡음(랜덤값) 삽입 | |
|RandomRoundingOperator |ksb.csle.didentification.privacy.<br>RandomRoundingOperator |숫자형, 문자열 데이터 올림, 반올림, 내림 | |
|RearrangeOperator |ksb.csle.didentification.privacy.<br>RearrangeOperator |레코드 교환기 | |
|RecordReductionOperator |ksb.csle.didentification.privacy.<br>RecordReductionOperator |outlier값 갖는 레코드 전체 값 대체 | |
|RoundingOperator |ksb.csle.didentification.privacy.<br>RoundingOperator |숫자형 데이터 올림, 반올림, 내림 | |
|SwappingOperator |ksb.csle.didentification.privacy.<br>SwappingOperator |레코드를 특정 값으로 변환 | |
<br>
## Runner
###ksb.csle.component.runner
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|KBEServingRunner |ksb.csle.component.runner.<br>KBEServingRunner | 지식베이스 엔진 쿼리 서빙 실행기| |
|PySparkRunner |ksb.csle.component.runner.<br>PySparkRunner |Spark MLlib을 이용한 training과 prediction을 위한 AutoML용 Spark 실행기 | |
|ServingRunner| ksb.csle.component.runner.<br>ServingRunner |Akka 기반의 REST API Service 용 REST 서버 실행기| |
|SimpleSparkRunner |ksb.csle.component.runner.<br>SimpleSparkRunner |Spark 범용 실행기| |
|TensorflowServingRunner |ksb.csle.component.runner.<br>TensorflowServingRunner|텐서플로우 모델 서빙 실행기| |
###ksb.csle.component.runner.analysis
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|TensorflowRunner |ksb.csle.component.runner.analysis.<br>TensorflowRunner |Train과 predict을 위한 텐서플로우 실행기| |
###ksb.csle.component.pipe.runner
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|ServingPipeRunner |ksb.csle.component.pipe.runner.<br>ServingPipeRunner |온디멘드 오퍼레이터 파이프라인용 Rest 서버 실행기 | |
<br>
## Controller
###ksb.csle.component.controller
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|BatchDummyController|ksb.csle.component.controller.<br>BatchDummyController|배치 입출력용 컨트롤러| |
|ExternalAnalysisController|ksb.csle.component.controller.<br>ExternalAnalysisController|데이터 분석기 컨트롤러 (텐서플로우 학습)| |
|KBEServingController|ksb.csle.component.controller.<br>KBEServingController|지식베이스 엔진 기반 서빙 컨트롤러| |
|ServingWithKbController|ksb.csle.component.controller.<br>ServingWithKbController | ML/Context 융합 Serving 컨트롤러 | |
|SparkSessionController | ksb.csle.component.controller.<br>SparkSessionController | Spark기반 제어용 컨트롤러 | |
|SparkSessionOrStreamController |ksb.csle.component.controller.<br>SparkSessionOrStreamController |SparkSession/Stream 통합 컨트롤러 | |
|SparkStreamController |ksb.csle.component.controller.<br>SparkStreamController |스트림 데이터 처리를 위한 제어기 | |
|TensorflowServingController |ksb.csle.component.controller.<br>TensorflowServingController |텐서플로우 기반 서빙 컨트롤러 | |
|WindowedSparkSessionOr<br>StreamController |ksb.csle.component.controller.<br>WindowedSparkSessionOrStreamController |윈도우 기능이 있는 Spark과 스트림 데이터 컨트롤러 | |
|PySparkMLTrainer| - |Spark ML 학습용 컨트롤러| |
###ksb.csle.component.pipe.controller
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|OnDemandCompositeServingRestfulController |ksb.csle.component.pipe.controller.<br>OnDemandCompositeServingRestfulController |온디멘드 Rest 방식의 API 융합서빙 컨트롤러 |
|OnDemandGenericController |ksb.csle.component.pipe.controller.<br>OnDemandGenericController |OnDemand 복합 컨트롤러 | |
|StreamingGenericController |ksb.csle.component.pipe.controller.<br>StreamingGenericController |스트림 파이프라인용 컨트롤러 | |