Newer
Older
# Component List (v19.03)
KSB 인공지능 프레임워크가 기본적으로 제공하는 컴포넌트의 목록입니다.
## 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 기반 데이터 입력기 | |
| 컴포넌트 이름 | 구현 클래스명 | 설명 |
|-------------|-------------|------------|
| 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
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|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 기반 데이터 출력기 | |
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|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
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|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="https://etrioss.kr/thkimetri/ksb19.03-manual/tree/master/manual1903/operator/4.1.1.8.AgglomerativeClustering_manual.md" > Link</a> |
|DBScanOperator |ksb.csle.component.operator.cleaning.<br>DBScanOperator |DBSCAN 클러스터링 처리기 | <a href="https://etrioss.kr/thkimetri/ksb19.03-manual/tree/master/manual1903/operator/4.1.1.1.DBSCAN_manual.md"> Link </a> |
|EMClusteringOperator |ksb.csle.component.operator.cleaning.<br>EMClusteringOperator |EM 클러스터링 처리기 | <a href="https://etrioss.kr/thkimetri/ksb19.03-manual/tree/master/manual1903/operator/4.1.1.2.EMClustering_manual.md">Link</a> |
|EqualDepthBinningOperator |ksb.csle.component.operator.cleaning.<br>EqualDepthBinningOperator |동일 빈도수 이산화 처리기 |<a href="https://etrioss.kr/thkimetri/ksb19.03-manual/tree/master/manual1903/operator/4.1.1.3.EqualDepthBinning_manual.md" > Link</a> |
|EqualWidthBinningOperator |ksb.csle.component.operator.cleaning.<br>EqualWidthBinningOperator |동일 폭 이산화 처리기 | <a href="https://etrioss.kr/thkimetri/ksb19.03-manual/tree/master/manual1903/operator/4.1.1.6.EqualWidthBinning_manual.md" > Link</a> |
|GeneralizedLinearRegressionOperator |ksb.csle.component.operator.cleaning.<br>GeneralizedLinearRegressionOperator |Generalized Linear Regression 처리기 | <a href="./operator/4.1.1.9.GeneralizedLinearRegression_manual.md" > Link</a> |
|KMeansOperator |ksb.csle.component.operator.cleaning.<br>KMeansOperator |Kmeans 클러스터링 처리기 | <a href="https://etrioss.kr/thkimetri/ksb19.03-manual/tree/master/manual1903/operator/4.1.1.4.KMeans_manual.md" > Link</a> |
|KMedoidsOperator |ksb.csle.component.operator.cleaning.<br>KMedoidsOperator |KMedoids 클러스터링 처리기 | <a href="https://etrioss.kr/thkimetri/ksb19.03-manual/tree/master/manual1903/operator/4.1.1.5.KMedoids_manual.md" > Link</a>
|LinearRegressionOperator |ksb.csle.component.operator.cleaning.<br>LinearRegressionOperator |Linear Regression 처리기 | <a href="https://etrioss.kr/thkimetri/ksb19.03-manual/tree/master/manual1903/operator/4.1.1.7.LinearRegression_manual.md" > Link</a> |
|MissingValueImputeOperator |ksb.csle.component.operator.cleaning.<br>MissingValueImputeOperator |데이터 공백 처리기 |<a href="https://etrioss.kr/thkimetri/ksb19.03-manual/tree/master/manual1903/operator/4.1.1.10.MissingValueImpute_manual.md" > Link</a> |
|컴포넌트 이름 | 구현 클래스명 | 설명 | 관련 링크|
|---|---|---|---|
|ConcatAndReshapeOperator |ksb.csle.component.operator.integration.<br>ConcatAndReshapeOperator |다수의 column을 조합하여 새로운 column 생성기| <a href="https://etrioss.kr/thkimetri/ksb19.03-manual/tree/master/manual1903/operator/4.1.1.11.ConcatAndReshape_manual.md" > Link</a> |
|GroupByOperator |ksb.csle.component.operator.integration.<br>GroupByOperator |특정 조건에 따른 해당 column의 grouping 처리기 | <a href="https://etrioss.kr/thkimetri/ksb19.03-manual/tree/master/manual1903/operator/4.1.1.12.GroupBy_manual.md" > Link</a> |
|OrderByOperator |ksb.csle.component.operator.integration.<br>OrderByOperator |오름차순, 내림차순에 따라 row 정렬 처리기 | <a href="https://etrioss.kr/thkimetri/ksb19.03-manual/tree/master/manual1903/operator/4.1.1.13.OrderBy_manual.md" > Link</a> |
|TimeIndexAddOperator |ksb.csle.component.operator.integration.<br>TimeIndexAddOperator |Unix timestamp column 삽입 처리기 | <a href="https://etrioss.kr/thkimetri/ksb19.03-manual/tree/master/manual1903/operator/4.1.1.14.TimeIndexAdd_manual.md" > Link</a> |
|VectorAssembleColumnAddOperator |ksb.csle.component.operator.integration.<br>VectorAssembleColumnAddOperator |Spark ML 동작을 위한 Vector assemble 처리기 | |
|AggregateOperator |ksb.csle.component.operator.reduction.<br>AggregateOperator |숫자형 데이터 통계값 (min, max, avg, std, count) 대체 |<a href="https://etrioss.kr/thkimetri/ksb19.03-manual/tree/master/manual1903/operator/4.1.1.16.Aggregate_manual.md" > Link</a> |
|ChiSquareSelectOperator |ksb.csle.component.operator.reduction.<br>ChiSquareSelectOperator |Chi-Square test를 이용한 column 선택처리기 |<a href="https://etrioss.kr/thkimetri/ksb19.03-manual/tree/master/manual1903/operator/4.1.1.17.ChiSquareSelect_manual.md" > Link</a> |
|ColumnRemoveOperator |ksb.csle.component.operator.reduction.<br>ColumnRemoveOperator |선택한 column들 삭제 처리기 | <a href="https://etrioss.kr/thkimetri/ksb19.03-manual/tree/master/manual1903/operator/4.1.1.18.ColumnRemove_manual.md" > Link</a> |
|ColumnSelectOperator |ksb.csle.component.operator.reduction.<br>ColumnSelectOperator |column 선택 및 재배열 처리기 |<a href="https://etrioss.kr/thkimetri/ksb19.03-manual/tree/master/manual1903/operator/4.1.1.19.ColumnSelect_manual.md" > Link</a> |
|ColumnSelectWithFileOperator |ksb.csle.component.operator.reduction.<br>ColumnSelectWithFileOperator |파일로부터 칼럼 선택 및 재배열 처리기 | |
|DecisionTreeInductOperator |ksb.csle.component.operator.reduction.<br>DecisionTreeInductOperator |Decision Tree Induction을 이용한 column 선택처리기 |<a href="https://etrioss.kr/thkimetri/ksb19.03-manual/tree/master/manual1903/operator/4.1.1.20.DecisionTreeInduct_manual.md" > Link</a> |
|FilterOperator |ksb.csle.component.operator.reduction.<br>FilterOperator |특정 조건에 따른 row 필터 처리기 |<a href="https://etrioss.kr/thkimetri/ksb19.03-manual/tree/master/manual1903/operator/4.1.1.21.Filter_manual.md" > Link</a> |
|FilterUsingSqlOperator |ksb.csle.component.operator.reduction.<br>FilterUsingSqlOperator |SQL을 이용한 row 필터 처리기 |<a href="https://etrioss.kr/thkimetri/ksb19.03-manual/tree/master/manual1903/operator/4.1.1.22.FilterUsingSql_manual.md" > 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="https://etrioss.kr/thkimetri/ksb19.03-manual/tree/master/manual1903/operator/4.1.1.23.PCA_manual.md" > Link</a> |
|RandomSamplingOperator |ksb.csle.component.operator.reduction.<br>RandomSamplingOperator |단순 무작위 표본 추출 처리기 | <a href="https://etrioss.kr/thkimetri/ksb19.03-manual/tree/master/manual1903/operator/4.1.1.24.RandomSampling_manual.md" > Link</a> |
|StepwiseBackwardEliminateOperator |ksb.csle.component.operator.reduction.<br>StepwiseBackwardEliminateOperator |Stepwise Backward Elimination를 이용한 column 선택처리기 |<a href="https://etrioss.kr/thkimetri/ksb19.03-manual/tree/master/manual1903/operator/4.1.1.25.StepwiseBackwardEliminate_manual.md" > Link</a> |
|StepwiseForwardSelectOperator |ksb.csle.component.operator.reduction.<br>StepwiseForwardSelectOperator |Stepwise Forward Selection를 이용한 column 선택처리기 | <a href="https://etrioss.kr/thkimetri/ksb19.03-manual/tree/master/manual1903/operator/4.1.1.26.StepwiseForwardSelect_manual.md" > Link</a> |
|StratifiedSamplingOperator |ksb.csle.component.operator.reduction.<br>StratifiedSamplingOperator |계층화된 샘플에서 표본 추출 처리기 | <a href="https://etrioss.kr/thkimetri/ksb19.03-manual/tree/master/manual1903/operator/4.1.1.27.StratifiedSampling_manual.md" > Link</a> |
|TimeWindowAggregateOperator |ksb.csle.component.operator.reduction.<br>TimeWindowAggregateOperator |Unit timestamp 정보를 이용하여 시간정보에 따라 aggregation 처리기 | |
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|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="https://etrioss.kr/thkimetri/ksb19.03-manual/tree/master/manual1903/operator/4.1.1.29.Interpolate_manual.md" > Link</a> |
|MinMaxScalingOperator |ksb.csle.component.operator.transformation.<br>MinMaxScalingOperator |최소/최대값을 기준으로 스케일링 처리기 | <a href="https://etrioss.kr/thkimetri/ksb19.03-manual/tree/master/manual1903/operator/4.1.1.30.MinMaxScaling_manual.md" > 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="https://etrioss.kr/thkimetri/ksb19.03-manual/tree/master/manual1903/operator/4.1.1.32.OneHotEncoding_manual.md" > Link</a> |
|PivotOperator |ksb.csle.component.operator.transformation.<br>PivotOperator | 특정 column 내 값을 row의 schema 정보로 변환 처리기 |<a href="https://etrioss.kr/thkimetri/ksb19.03-manual/tree/master/manual1903/operator/4.1.1.33.Pivot_manual.md" > 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="https://etrioss.kr/thkimetri/ksb19.03-manual/tree/master/manual1903/operator/4.1.1.35.SelectWithTimeWindow_manual.md" > 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="https://etrioss.kr/thkimetri/ksb19.03-manual/tree/master/manual1903/operator/4.1.1.37.Transpose_manual.md" > Link</a> |
|VectorizeColumnOperator |ksb.csle.component.operator.transformation.<br>VectorizeColumnOperator |여러 column들을 모아서 하나의 vector 타입 column을 생성 | |
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|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 |쿼리 기반 경로 컨텍스트 변환 오퍼레이터 | |
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|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 |스트림 방식의 시간 조인 파이프라인 오퍼레이터 | |
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|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
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|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|텐서플로우 모델 서빙 실행기| |
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|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
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|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 학습용 컨트롤러| |
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|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 |스트림 파이프라인용 컨트롤러 | |