Skip to content

Commit

Permalink
In PySpark Estimator example use the model with validation_indicator (#…
Browse files Browse the repository at this point in the history
…8131)

* use the validation_indicator model

* use the validation_indicator model for regression
  • Loading branch information
praateekmahajan committed Aug 3, 2022
1 parent d87f692 commit ff471b3
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions demo/guide-python/spark_estimator_examples.py
Expand Up @@ -48,7 +48,7 @@ def create_spark_df(X, y):

# train xgboost regressor model with validation dataset
xgb_regressor2 = SparkXGBRegressor(max_depth=5, validation_indicator_col="validationIndicatorCol")
xgb_regressor_model2 = xgb_regressor.fit(diabetes_train_spark_df2)
xgb_regressor_model2 = xgb_regressor2.fit(diabetes_train_spark_df2)
transformed_diabetes_test_spark_df2 = xgb_regressor_model2.transform(diabetes_test_spark_df)
print(f"regressor2 rmse={regressor_evaluator.evaluate(transformed_diabetes_test_spark_df2)}")

Expand All @@ -75,7 +75,7 @@ def create_spark_df(X, y):

# train xgboost classifier model with validation dataset
xgb_classifier2 = SparkXGBClassifier(max_depth=5, validation_indicator_col="validationIndicatorCol")
xgb_classifier_model2 = xgb_classifier.fit(iris_train_spark_df2)
xgb_classifier_model2 = xgb_classifier2.fit(iris_train_spark_df2)
transformed_iris_test_spark_df2 = xgb_classifier_model2.transform(iris_test_spark_df)
print(f"classifier2 f1={classifier_evaluator.evaluate(transformed_iris_test_spark_df2)}")

Expand Down

0 comments on commit ff471b3

Please sign in to comment.