如何在 Spark 中将 LogisticRegressionWIthLBFGS 与 Dataframe 一起使用

How to use LogisticRegressionWIthLBFGS with a Dataframe in Spark

我想在旨在使用 ML 算法和数据帧的程序中使用 MLLIB LogisticRegressionWithLBFGS。 有没有一种简单的方法可以将我的数据帧转换为 RDD 而无需再次编写新程序? 这样的事情不起作用:

df3.cache()
val model = new LogisticRegressionWithLBFGS().run(df3.rdd)
val predictions = model.transform(df3)

您必须将 df3.rdd[Row] 映射到 RDD[LabeledPoint]

所以这取决于你的模式和所有。