ojsl 发表于 2018-6-10 16:52

sparksession.read的问题,求解

val lines = spark.read.text("H:/data/wordcount").as[String]发生报错Error:(16, 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").asError:(16, 56) not enough arguments for method as: (implicit evidence$2: org.apache.spark.sql.Encoder)org.apache.spark.sql.Dataset.Unspecified value parameter evidence$2.    val lines = spark.read.text("H:/data/wordcount").as
页: [1]
查看完整版本: sparksession.read的问题,求解