val sqlContext =新org.apache.spark.sql.SQLContext(sc) sqlContext.createSchemaRDD val people = sc.textFile("c3/test.txt").map(_.split(",")).map(p => Person(p(0),p(1).trim.toInt)) people.registerTempTable("people")
除了sqlContext以外,还有其他方法将SchemaRDD转换为imp
我按照指令加载本地pmml模型,代码如下所示import org.jpmml.evaluator.spark._import org.apache.spark.sql._
val new File(getClass.getClassLoader.getResource("random_forest.pmml").getFile)
val evaluator = EvaluatorUt
当我被处决时在我的星星之火应用程序中,错误显示如下:
从日志中选择*,其中的内容如%流%^ at org.apache.spark.sql.catalyst.AbstractSparkSQLParser.apply(AbstractSparkSQLParser.scala:40) at org.apache.spark.sql.SQLC