【发布时间】:2018-04-28 22:14:50
【问题描述】:
我正在尝试在 python 脚本上使用 PySpark API 从 spark 应用程序执行 pca。我这样做:
pca = PCA(k=3, inputCol="features", outputCol="pcaFeatures")
PCAmodel = pca.fit(data)
当我在 pyspark shell 中运行这两个代码行时,它可以工作并返回良好的结果,但是在应用程序脚本中,我得到了错误类型:
PCA() 得到了一个意外的关键字参数“k”
PS:在这两种情况下,我都使用 Spark 2.2.0
问题出在哪里?为什么它在 PySpark shell 中工作而不是在应用程序中工作?
【问题讨论】:
-
我使用的是 spark 2.2.0
标签: pyspark pca apache-spark-ml