您的位置:首页 > 大数据 > 人工智能

No TypeTag available for person

2016-05-16 22:26 591 查看
参考源文:http://stackoverflow.com/questions/29143756/scala-spark-app-with-no-typetag-available-error-in-def-main-style-app

集群环境下spark-shell测试正常:

val person = sc.textFile("examples/src/main/resources/person.txt").map(_.split(",")).map(p => Person(p(0), p(1).trim.toInt)).toDF()

本地开发环境测试本地文件:

case class Person(name : String, age : Int)
val person = sc.textFile("file:///E:/df/SPARK/datas/person.txt").map(_.split("\n")).map(p => Person(p(0), p(1).trim.toInt)).toDF()

编译报错:

Error:(21, 92) No TypeTag available for Person
val person = sc.textFile("file:///E:/df/SPARK/datas/person.txt").map(_.split("\n")).map(p => Person(p(0), p(1).trim.toInt)).toDF()
^
把case class移到方法外即可
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: