transformation

cleaning

reduction

ControlContextProtocol

components

runner

MlKbServingActor ServingActor

ServerStopArgs

root

operator runner

DLTrainOperator SparkMLPredictOperator AgglomerativeClusteringOperator DBScanOperator EMClusteringOperator EqualDepthBinningOperator EqualWidthBinningOperator GeneralizedLinearRegressionOperator KMeansOperator KMedoidsOperator LinearRegressionOperator MissingValueImputeOperator GroupByOperator OrderByOperator ReshapeWithConcat TimeIndexAddOperator VectorAssembleColumnAddOperator AggregateOperator ChiSquareSelectOperator ColumnRemoveOperator ColumnSelectOperator ColumnSelectWithFileOperator DecisionTreeInductOperator FilterOperator FilterUsingSqlOperator GroupByFilterOperator OrderByFilterOperator PCAOperator RandomSamplingOperator StepwiseBackwardEliminateOperator StepwiseForwardSelectOperator StratifiedSamplingOperator TimeWindowAggregateOperator ControlContextQueryOperator WeatherQueryOperator MinMaxScalingOperator NullReplaceOperator OneHotEncodingOperator PivotOperator ReshapeWithTimeWindowOperator SelectWithTimeWindowOperator TransposeOperator FileReader KafkaOnDemandReader KafkaReader MongodbReader MultipleReaders PhoenixReader PhoenixReaderBySql ServingRunner FileWriter KafkaWriter PhoenixWriter StdoutWriter