查看: 550|回复: 0

sparksession.read的问题,求解

[复制链接]
新浪微博达人勋 ojsl 实名认证
论坛徽章:
9
比特币徽章
日期:2017-09-28 17:18:05Oracle研习者初级
日期:2017-10-26 15:09:26spark徽章
日期:2017-11-23 16:58:48机器学习徽章
日期:2017-11-30 15:59:35算法导论徽章
日期:2017-12-28 17:08:38智慧眼徽章
日期:2018-03-19 15:05:00spark徽章
日期:2018-06-14 15:36:26spark徽章
日期:2018-08-24 10:52:51人工智能徽章
日期:2018-09-03 15:45:32
发表于 2018-6-10 16:52 | 显示全部楼层 |阅读模式

Spark

val lines = spark.read.text("H:/data/wordcount").as[String]发生报错Error16, 56) Unable to find encoder for type stored in a Dataset.  Primitive types (Int, String, etc) and Product types (case classes) are supported by importing spark.implicits._  Support for serializing other types will be added in future releases.    val lines = spark.read.text("H:/data/wordcount".as[String]Error:(16, 56) not enough arguments for method as: (implicit evidence$2: org.apache.spark.SQL.Encoder[String])org.apache.spark.sql.Dataset[String].Unspecified value parameter evidence$2.    val lines = spark.read.text("H:/data/wordcount").as[String]
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册 新浪微博登陆

本版积分规则

 

GMT+8, 2018-11-16 21:48 , Processed in 0.114651 second(s), 29 queries .