ValueError:在pyspark中尝试在非包中相对导入。当我尝试在 pyspark 中使用 kmode 时出现上述错误。所以我使用sc.addFile("home/pyspark-distributedkmodesmaster/pyspark_kmodes/pyspark_kmodes.py") .如果我不使用sc上下文添加文件代码,则会抛出错误-"找不到kmodes模块"。我正在使用以下代码/链接或 kmode pyspark 包 -"https://github.com/ThinkBigAnalytics/pyspark-distributed-kmodes/blob/master/pyspark_kmodes"
它是一个包,你只部署其中包含的一个 py 文件。由于pyspark_kmodes.py
中存在相对导入:
from .Kmodes import KModes
.Kmodes
中的.
表示它应该在同一文件夹中查找文件KModes.py
(在包文件夹中)