Довольно плохо знаком с scala.
У меня есть оператор if else, который на основе условия присваивает значение переменной.
import org.apache.spark.ml.{Pipeline, PipelineModel, PipelineStage}
modelType = "rf"
def train(trainingData: DataFrame): PipelineModel = {
val xgb = new XGBoostClassifier()
.setLabelCol("label")
.setFeaturesCol("features")
.setObjective("binary:logistic")
.setEvalMetric("auc")
val rf = new RandomForestClassifier()
.setLabelCol("label")
.setFeaturesCol("features")
.setImpurity("gini")
if (modelType == "rf") {
val pipeline = new Pipeline()
.setStages(Array[PipelineStage](rf))
} else if (modelType == "xgb") {
val pipeline = new Pipeline()
.setStages(Array[PipelineStage](rf))
}
pipeline.fit(trainingData)
}
Но я вижу эту ошибку: pipeline not found
.Означает ли это, что переменная конвейера не назначена?Как я могу переписать это?