Выполнение PMML в Spark для прогнозов

Question

Я новичок в файлах pmml.У меня есть файл pmml (который содержит некоторую информацию о модели).мы хотим обработать этот файл pmml в spark для прогнозов.

В результате выполнения он даст некоторые значения прогноза в качестве целевых полей и полей.

как обработать pmml в spark scala?

Любой пример / документация, пожалуйста.

Answer 1

Вы можете использовать PMML4S-Spark для обработки PMML в Spark Scala, например:

import org.pmml4s.spark.ScoreModel

val model = ScoreModel.fromFile("the/pmml/file/path")
val scoreDf = model.transform(df)

scoreDf - это Spark DataFrame с полями, которые определяются вашим pmml.