# Component List (v19.03)
KSB 인공지능 프레임워크가 기본적으로 제공하는 컴포넌트의 목록입니다.
## Reader
###ksb.csle.component.reader
| 컴포넌트 이름 | 구현 클래스명 | 설명 |
|-------------|-------------|------------|
| FileReader | ksb.csle.component.reader.
FileReader | 파일 입력기 | |
| HttpClientReader |ksb.csle.component.reader.
HttpClientReader |HTTP 클라이언트 기반 데이터 입력기 | |
| HttpServerReader |ksb.csle.component.reader.
HttpServerReader |HTTP 서버 기반 데이터 입력기 | |
| HttpWeatherClientReader |ksb.csle.component.reader.
HttpWeatherClientReader |HTTP 클라이언트 기반 동네기상 데이터 입력기 | |
| KafkaOnDemandReader |ksb.csle.component.reader.
KafkaOnDemandReader | Kafka 데이터 입력기 | |
| KafkaReader |ksb.csle.component.reader.
KafkaReader | Kafka용 데이터 입력기 | |
| MongodbReader |ksb.csle.component.reader.
MongodbReader |Mongodb 데이터 입력기 | |
| MultipleReaders |ksb.csle.component.reader.
MultipleReaders |다중입력기 | |
| Onem2mHttpReader |ksb.csle.component.reader.
Onem2mHttpReader |OneM2M 데이터 입력기 | |
| PhoenixReader |ksb.csle.component.reader.
PhoenixReader |Phoenix 기반의 HBase 데이터 입력기 | |
| TableReader |ksb.csle.component.reader.
TableReader |JDBC 기반 데이터 입력기 | |
###ksb.csle.component.pipe.stream.reader
| 컴포넌트 이름 | 구현 클래스명 | 설명 |
|-------------|-------------|------------|
| FilePipeReader |ksb.csle.component.pipe.stream.reader.
FilePipeReader | 스트림 처리용 파일 입력기 | |
| KafkaContextQueryPipeReader | ksb.csle.component.pipe.stream.reader.
KafkaContextQueryPipeReader | Kafka 토픽 쿼리 파이프라인 입력기 | |
| KafkaPipeReader | ksb.csle.component.pipe.stream.reader.
KafkaPipeReader |카프카 스트림 입력기 | |
## writer
###ksb.csle.component.writer
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|FileWriter |ksb.csle.component.writer.
FileWriter |파일 출력기| |
|HttpClientWriter | ksb.csle.component.writer.
HttpClientWriter | HTTP 클라이언트 기반 데이터 출력기 | |
|KafkaWriter |ksb.csle.component.writer.
KafkaWriter | Kafka 데이터 출력기 | |
|MongodbWriter |ksb.csle.component.writer.
MongodbWriter |Mongodb 데이터 출력기| |
|PhoenixWriter |ksb.csle.component.writer.
PhoenixWriter |Phoenix 기반의 HBase 데이터 출력기| |
|StdoutWriter |ksb.csle.component.writer.
StdoutWriter |표준출력(콘솔화면) 데이터 출력기| |
|TableWriter |ksb.csle.component.writer.
TableWriter |JDBC 기반 데이터 출력기 | |
###ksb.csle.component.pipe.stream.writer
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|ConsolePipeWriter |ksb.csle.component.pipe.stream.writer.
ConsolePipeWriter |콘솔 스트림 출력기 | |
|FilePipeWriter |ksb.csle.component.pipe.stream.writer.
FilePipeWriter |파일 스트림 출력기 | |
|HBasePipeWriter |ksb.csle.component.pipe.stream.writer.
HBasePipeWriter |HBase 스트림 출력기| |
|KafkaPipeWriter|ksb.csle.component.pipe.stream.writer.
KafkaPipeWriter |카프카 스트림 출력기 | |
|MemoryPipeWriter| ksb.csle.component.pipe.stream.writer.
MemoryPipeWriter |스트림 출력기 | |
## Operator
###ksb.csle.component.operator.analysis
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|DLTrainOperator |ksb.csle.component.operator.analysis.
DLTrainOperator |텐서플로우 딥러닝 학습용 처리기 | |
|RandomForestClassifierPredictOperator |ksb.csle.component.operator.analysis.
RandomForestClassifierPredictOperator |RandomForest 분류 모델을 이용하여 label 예측 | |
|RandomForestClassifierTrainOperator |ksb.csle.component.operator.analysis.
RandomForestClassifierTrainOperator |RandomForest 분류 모델 생성 | |
|SparkMLPredictOperator |ksb.csle.component.operator.analysis.
SparkMLPredictOperator |SparkML 예측 처리기 | |
|TensorflowPredictOperator |ksb.csle.component.operator.analysis.
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.
AgglomerativeClusteringOperator |Agglomerative 클러스터링 처리기 | Link |
|DBScanOperator |ksb.csle.component.operator.cleaning.
DBScanOperator |DBSCAN 클러스터링 처리기 | Link |
|EMClusteringOperator |ksb.csle.component.operator.cleaning.
EMClusteringOperator |EM 클러스터링 처리기 | Link |
|EqualDepthBinningOperator |ksb.csle.component.operator.cleaning.
EqualDepthBinningOperator |동일 빈도수 이산화 처리기 | Link |
|EqualWidthBinningOperator |ksb.csle.component.operator.cleaning.
EqualWidthBinningOperator |동일 폭 이산화 처리기 | Link |
|GeneralizedLinearRegressionOperator |ksb.csle.component.operator.cleaning.
GeneralizedLinearRegressionOperator |Generalized Linear Regression 처리기 | Link |
|KMeansOperator |ksb.csle.component.operator.cleaning.
KMeansOperator |Kmeans 클러스터링 처리기 | Link |
|KMedoidsOperator |ksb.csle.component.operator.cleaning.
KMedoidsOperator |KMedoids 클러스터링 처리기 | Link
|LinearRegressionOperator |ksb.csle.component.operator.cleaning.
LinearRegressionOperator |Linear Regression 처리기 | Link |
|MissingValueImputeOperator |ksb.csle.component.operator.cleaning.
MissingValueImputeOperator |데이터 공백 처리기 | Link |
###ksb.csle.component.operator.integration
|컴포넌트 이름 | 구현 클래스명 | 설명 | 관련 링크|
|---|---|---|---|
|ConcatAndReshapeOperator |ksb.csle.component.operator.integration.
ConcatAndReshapeOperator |다수의 column을 조합하여 새로운 column 생성기| Link |
|GroupByOperator |ksb.csle.component.operator.integration.
GroupByOperator |특정 조건에 따른 해당 column의 grouping 처리기 | Link |
|OrderByOperator |ksb.csle.component.operator.integration.
OrderByOperator |오름차순, 내림차순에 따라 row 정렬 처리기 | Link |
|TimeIndexAddOperator |ksb.csle.component.operator.integration.
TimeIndexAddOperator |Unix timestamp column 삽입 처리기 | Link |
|VectorAssembleColumnAddOperator |ksb.csle.component.operator.integration.
VectorAssembleColumnAddOperator |Spark ML 동작을 위한 Vector assemble 처리기 | |
###ksb.csle.component.operator.reduction
|컴포넌트 이름 | 구현 클래스명 | 설명 | 관련 링크|
|---|---|---|---|
|AggregateOperator |ksb.csle.component.operator.reduction.
AggregateOperator |숫자형 데이터 통계값 (min, max, avg, std, count) 대체 | Link |
|ChiSquareSelectOperator |ksb.csle.component.operator.reduction.
ChiSquareSelectOperator |Chi-Square test를 이용한 column 선택처리기 | Link |
|ColumnRemoveOperator |ksb.csle.component.operator.reduction.
ColumnRemoveOperator |선택한 column들 삭제 처리기 | Link |
|ColumnSelectOperator |ksb.csle.component.operator.reduction.
ColumnSelectOperator |column 선택 및 재배열 처리기 | Link |
|ColumnSelectWithFileOperator |ksb.csle.component.operator.reduction.
ColumnSelectWithFileOperator |파일로부터 칼럼 선택 및 재배열 처리기 | |
|DecisionTreeInductOperator |ksb.csle.component.operator.reduction.
DecisionTreeInductOperator |Decision Tree Induction을 이용한 column 선택처리기 | Link |
|FilterOperator |ksb.csle.component.operator.reduction.
FilterOperator |특정 조건에 따른 row 필터 처리기 | Link |
|FilterUsingSqlOperator |ksb.csle.component.operator.reduction.
FilterUsingSqlOperator |SQL을 이용한 row 필터 처리기 | Link |
|GroupByFilterOperator |ksb.csle.component.operator.reduction.
GroupByFilterOperator |총계처리 후 필터링 | |
|OrderByFilterOperator |ksb.csle.component.operator.reduction.
OrderByFilterOperator |정렬 후 필터링 | |
|PCAOperator |ksb.csle.component.operator.reduction.
PCAOperator |PCA를 이용한 column 생성 처리기 | Link |
|RandomSamplingOperator |ksb.csle.component.operator.reduction.
RandomSamplingOperator |단순 무작위 표본 추출 처리기 | Link |
|StepwiseBackwardEliminateOperator |ksb.csle.component.operator.reduction.
StepwiseBackwardEliminateOperator |Stepwise Backward Elimination를 이용한 column 선택처리기 | Link |
|StepwiseForwardSelectOperator |ksb.csle.component.operator.reduction.
StepwiseForwardSelectOperator |Stepwise Forward Selection를 이용한 column 선택처리기 | Link |
|StratifiedSamplingOperator |ksb.csle.component.operator.reduction.
StratifiedSamplingOperator |계층화된 샘플에서 표본 추출 처리기 | Link |
|TimeWindowAggregateOperator |ksb.csle.component.operator.reduction.
TimeWindowAggregateOperator |Unit timestamp 정보를 이용하여 시간정보에 따라 aggregation 처리기 | |
###ksb.csle.component.operator.service
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|ControlContextQueryOperator |ksb.csle.component.operator.service.
ControlContextQueryOperator |컨텍스트 및 제어 쿼리 처리기 | |
|TensorflowServingOperator |ksb.csle.component.operator.service.
TensorflowServingOperator |텐서플로우 모델 예측 처리기 | |
|WeatherQueryOperator |ksb.csle.component.operator.service.
WeatherQueryOperator |지식베이스 엔진 쿼리 처리기 | |
###ksb.csle.component.operator.transformation
|컴포넌트 이름 | 구현 클래스명 | 설명 | 관련 링크|
|---|---|---|---|
|AddConditionalColumnOperator |ksb.csle.component.operator.transformation.
AddConditionalColumnOperator |주어진 조건에 의해 새로운 column 생성 | |
|ChangeColumnDataTypeOperator |ksb.csle.component.operator.transformation.
ChangeColumnDataTypeOperator |column의 데이터 타입 변경 | |
|ExplodeColumnOperator |ksb.csle.component.operator.transformation.
ExplodeColumnOperator |array/map 타입 column의 각 element로부터 새로운 row 생성 | |
|FlattenOperator |ksb.csle.component.operator.transformation.
FlattenOperator |선택한 column의 모든 row을 하나의 row로 합치는 처리기 | |
|InterpolateOperator |ksb.csle.component.operator.transformation.
InterpolateOperator |일정한 간격으로 데이터를 보간하여 새로운 데이터프레임 생성 | Link |
|MinMaxScalingOperator |ksb.csle.component.operator.transformation.
MinMaxScalingOperator |최소/최대값을 기준으로 스케일링 처리기 | Link |
|NullReplaceOperator |ksb.csle.component.operator.transformation.
NullReplaceOperator |공백문자나 Zero 값 Null 대체기 | |
|OneHotEncodingOperator |ksb.csle.component.operator.transformation.
OneHotEncodingOperator |One-Hot-Encoding 처리기 | Link |
|PivotOperator |ksb.csle.component.operator.transformation.
PivotOperator | 특정 column 내 값을 row의 schema 정보로 변환 처리기 | Link |
|RenameColumnOperator |ksb.csle.component.operator.transformation.
RenameColumnOperator |column 이름 변경 | | |
|ReshapeWithTimeWindowOperator |ksb.csle.component.operator.transformation.
ReshapeWithTimeWindowOperator |Time window 값에 따라 shift된 row 생성 처리기 ||
|SelectWithTimeWindowOperator |ksb.csle.component.operator.transformation.
SelectWithTimeWindowOperator |Time window 값에 따라 shift된 row 선택 처리기 | Link |
|SplitColumnOperator |ksb.csle.component.operator.transformation.
SplitColumnOperator |array/map 타입 column의 element를 각 column으로 분리 | |
|StringIndexOperator |ksb.csle.component.operator.transformation.
StringIndexOperator |문자열 타입의 컬럼에 대한 색인 컬럼을 생성 | |
|TimeSynchronizeOperator |ksb.csle.component.operator.transformation.
TimeSynchronizeOperator |시간(timestamp)을 동기화하여 두 개의 데이터프레임 join | |
|TransposeOperator |ksb.csle.component.operator.transformation.
TransposeOperator |하나의 dataframe column을 row로 변환 처리기| Link |
|VectorizeColumnOperator |ksb.csle.component.operator.transformation.
VectorizeColumnOperator |여러 column들을 모아서 하나의 vector 타입 column을 생성 | |
###ksb.csle.component.pipe.query.operator
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|KafkaContextQueryPipeOperator |ksb.csle.component.pipe.query.operator.
KafkaContextQueryPipeOperator |카프카 OnDemand 쿼리용 | |
|OutputAggregatePipeOperator |ksb.csle.component.pipe.query.operator.
OutputAggregatePipeOperator |하나 이상의 질의결과를 축약하는 축약 오퍼레이터 | |
|OutputCumulativePipeOperator |ksb.csle.component.pipe.query.operator.
OutputCumulativePipeOperator |질의를 수행하고 전달되는 결과를 append하여 전달하는 질의 오퍼레이터 | |
|OutputRestfulContextQueryPipeOperator |ksb.csle.component.pipe.query.operator.
OutputRestfulContextQueryPipeOperator |질의를 수행하고 전달되는 결과를 단순전달하는 질의 오퍼레이터 | |
|RouteMappingPipeOperator |ksb.csle.component.pipe.query.operator.
RouteMappingPipeOperator |매핑 기반 경로 변환 오퍼레이터 | |
|RouteRestfulContextQueryPipeOperator |ksb.csle.component.pipe.query.operator.
RouteRestfulContextQueryPipeOperator |쿼리 기반 경로 컨텍스트 변환 오퍼레이터 | |
###ksb.csle.component.pipe.stream.operator
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|FilterOperator |ksb.csle.component.pipe.stream.operator.
FilterOperator |스트림 파이프라인용 필터 | |
|GroupByOperator |ksb.csle.component.pipe.stream.operator.
GroupByOperator |스트림 파이프라인용 그룹 처리기 | |
|OrderByOperator |ksb.csle.component.pipe.stream.operator.
OrderByOperator |스트림 파이프라인용 row 정렬 처리기 | |
|RenameColumnsPipeOperator |ksb.csle.component.pipe.stream.operator.
RenameColumnsPipeOperator |칼럼 이름 및 타입 변경 오퍼레이터 | |
|SelectColumnsPipeOperator |ksb.csle.component.pipe.stream.operator.
SelectColumnsPipeOperator |스트림 파이프라인용 칼럼 선택기 | |
|SparkMLPredictPipeOperator |ksb.csle.component.pipe.stream.operator.
SparkMLPredictPipeOperator | Pipeline기반 ML prediction용 operator | |
|StreamAllJoinOperator |ksb.csle.component.pipe.stream.operator.
StreamAllJoinOperator |스트림 key기반 칼럼결합기 | |
|StreamJoinOperator |ksb.csle.component.pipe.stream.operator.
StreamJoinOperator | 두 개 이상의 입력데이터로부터 같은 keyword의 데이터 결합| |
|StreamTimeJoinOperator |ksb.csle.component.pipe.stream.operator.
StreamTimeJoinOperator |스트림 방식의 시간 조인 파이프라인 오퍼레이터 | |
###ksb.csle.didentification.privacy
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|AggregationOperator |ksb.csle.didentification.privacy.
AggregationOperator |선택한 column들에 대한 aggregation 처리기 | |
|BlankImputeOperator |ksb.csle.didentification.privacy.
BlankImputeOperator |특정 위치에 공백 및 별표 처리 | |
|DataRangeOperator |ksb.csle.didentification.privacy.
DataRangeOperator |사용자 입력 기반 범주화 처리 | |
|EncryptionOperator |ksb.csle.didentification.privacy.
EncryptionOperator |SHA-1기반 암호화기 | |
|HeuristicOperator | ksb.csle.didentification.privacy.
HeuristicOperator |랜덤 스트링 기반 가명 처리기 | |
|HidingOperator |ksb.csle.didentification.privacy.
HidingOperator |문자열 데이터 통계값(최빈문자열 또는 ....) 대체 | |
|IdenReductionOperator |ksb.csle.didentification.privacy.
IdenReductionOperator |식별자 제거기 | |
|PartialAggregateOperator | ksb.csle.didentification.privacy.
PartialAggregateOperator |outlier값 갖는 cell 통계값 대체 | |
|PartialIdenReductionOperator |ksb.csle.didentification.privacy.
PartialIdenReductionOperator |식별자 중 ouliter값을 갖는 cell 값 대체 | |
|QuasiReductionOperator |ksb.csle.didentification.privacy.
QuasiReductionOperator |준식별자 제거 | |
|RandomNoiseOperator |ksb.csle.didentification.privacy.
RandomNoiseOperator |특정 위치에 잡음(랜덤값) 삽입 | |
|RandomRoundingOperator |ksb.csle.didentification.privacy.
RandomRoundingOperator |숫자형, 문자열 데이터 올림, 반올림, 내림 | |
|RearrangeOperator |ksb.csle.didentification.privacy.
RearrangeOperator |레코드 교환기 | |
|RecordReductionOperator |ksb.csle.didentification.privacy.
RecordReductionOperator |outlier값 갖는 레코드 전체 값 대체 | |
|RoundingOperator |ksb.csle.didentification.privacy.
RoundingOperator |숫자형 데이터 올림, 반올림, 내림 | |
|SwappingOperator |ksb.csle.didentification.privacy.
SwappingOperator |레코드를 특정 값으로 변환 | |
## Runner
###ksb.csle.component.runner
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|KBEServingRunner |ksb.csle.component.runner.
KBEServingRunner | 지식베이스 엔진 쿼리 서빙 실행기| |
|PySparkRunner |ksb.csle.component.runner.
PySparkRunner |Spark MLlib을 이용한 training과 prediction을 위한 AutoML용 Spark 실행기 | |
|ServingRunner| ksb.csle.component.runner.
ServingRunner |Akka 기반의 REST API Service 용 REST 서버 실행기| |
|SimpleSparkRunner |ksb.csle.component.runner.
SimpleSparkRunner |Spark 범용 실행기| |
|TensorflowServingRunner |ksb.csle.component.runner.
TensorflowServingRunner|텐서플로우 모델 서빙 실행기| |
###ksb.csle.component.runner.analysis
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|TensorflowRunner |ksb.csle.component.runner.analysis.
TensorflowRunner |Train과 predict을 위한 텐서플로우 실행기| |
###ksb.csle.component.pipe.runner
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|ServingPipeRunner |ksb.csle.component.pipe.runner.
ServingPipeRunner |온디멘드 오퍼레이터 파이프라인용 Rest 서버 실행기 | |
## Controller
###ksb.csle.component.controller
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|BatchDummyController|ksb.csle.component.controller.
BatchDummyController|배치 입출력용 컨트롤러| |
|ExternalAnalysisController|ksb.csle.component.controller.
ExternalAnalysisController|데이터 분석기 컨트롤러 (텐서플로우 학습)| |
|KBEServingController|ksb.csle.component.controller.
KBEServingController|지식베이스 엔진 기반 서빙 컨트롤러| |
|ServingWithKbController|ksb.csle.component.controller.
ServingWithKbController | ML/Context 융합 Serving 컨트롤러 | |
|SparkSessionController | ksb.csle.component.controller.
SparkSessionController | Spark기반 제어용 컨트롤러 | |
|SparkSessionOrStreamController |ksb.csle.component.controller.
SparkSessionOrStreamController |SparkSession/Stream 통합 컨트롤러 | |
|SparkStreamController |ksb.csle.component.controller.
SparkStreamController |스트림 데이터 처리를 위한 제어기 | |
|TensorflowServingController |ksb.csle.component.controller.
TensorflowServingController |텐서플로우 기반 서빙 컨트롤러 | |
|WindowedSparkSessionOr
StreamController |ksb.csle.component.controller.
WindowedSparkSessionOrStreamController |윈도우 기능이 있는 Spark과 스트림 데이터 컨트롤러 | |
|PySparkMLTrainer| - |Spark ML 학습용 컨트롤러| |
###ksb.csle.component.pipe.controller
|컴포넌트 이름 | 구현 클래스명 | 설명 |
|---|---|---|
|OnDemandCompositeServingRestfulController |ksb.csle.component.pipe.controller.
OnDemandCompositeServingRestfulController |온디멘드 Rest 방식의 API 융합서빙 컨트롤러 |
|OnDemandGenericController |ksb.csle.component.pipe.controller.
OnDemandGenericController |OnDemand 복합 컨트롤러 | |
|StreamingGenericController |ksb.csle.component.pipe.controller.
StreamingGenericController |스트림 파이프라인용 컨트롤러 | |