小编mat*_*sio的帖子

我正在尝试在 kafka-spark 流中创建一个数据帧，我已成功将值映射到案例类，但是每当我调用 toDF 方法时，它都会给我错误。**

value toDF 不是 Array[WeatherEvent] [错误] 的成员 可能的原因：可能在“value toDF”之前缺少分号？[错误]
}).toDF("经度", "纬度", "国家", "日出", "日落", "温度", "最低温度", "最高温度", [错误] ^ [错误] 发现一处错误[error] (compile:compileIncremental) 编译失败 [error] 总时间：2 s，完成 2017 年 9 月 27 日 11:49:23 AM

这是我的代码

 val inputStream = KafkaUtils.createDirectStream(ssc, PreferConsistent, Subscribe[String, String ](Array("test"), kafkaParams))
 //  val json = parse(inputStream)


  val processedStream = inputStream
  .flatMap(record => record.value.split(" ").map(payload => {
        //val ts = Timestamp.valueOf(payload(3))
        WeatherEvent(payload(0).toDouble, payload(1).toDouble, payload(2).toString , payload(3).toInt,
                    payload(4).toInt, payload(5).toDouble, payload(6).toDouble, payload(7).toDouble, 
                    payload(8).toDouble, payload(9).toInt, payload(10).toInt, payload(11).toInt, …