How to fit pipelines in spark random forest regressor?
pipeline = Pipeline(stages = pipeline_stages) pipeline_fit = pipeline.fit(df).transform(df) df = pipeline_fit.select(["features","balance"]) df.printSchema()
Not a member yet? Register now
Are you a member? Login now