如何在PySpark脚本中使用pmml模型？

Question

{{{cd2}被转换为PySpark脚本中使用这个模型，但是我没有主意，我如何实现它。有没有方法允许在Python中导入pmml模型并将其用于预测？谢谢你的建议。在

BR，
弗拉基米尔

Answer 1

您可以使用PyPMML-Spark在PySpark脚本中导入PMML，例如：

from pypmml_spark import ScoreModel

model = ScoreModel.fromFile('the/pmml/file/path')
score_df = model.transform(df)

Answer 2

Spark不支持直接从PMML导入。虽然我还没有遇到pyspark PMML导入器，但有一个用于java（https://github.com/jpmml/jpmml-evaluator-spark）的导入器。你能做的就是包装java（或scala），这样你就可以从python访问它（例如，参见http://aseigneurin.github.io/2016/09/01/spark-calling-scala-code-from-pyspark.html）。在