val receiverStream: ReceiverInputDStream[ String ] = RabbitMQUtils.createStream String
receiverStream.print()
receiverStream.map(value => {
//@transient val sc = spark.sparkContext
val jsonS = JSON.parseFull(value)
val mapjson: Map[ String, String ] = regJson(jsonS)
val alarmContent = mapjson.get("alarmContent").toString.replace("Some(", "").replace(")", "")
val alarmEventId = mapjson.get("alarmEventId").toString.replace("Some(", "").replace(")", "")
val alarmLevel = mapjson.get("alarmLevel").toString.replace("Some(", "").replace(")", "")
val alarmType = mapjson.get("alarmType").toString.replace("Some(", "").replace(")", "")
val buildingId = mapjson.get("buildingId").toString.replace("Some(", "").replace(")", "")
val chargesCode = mapjson.get("chargesCode").toString.replace("Some(", "").replace(")", "")
val createDate = mapjson.get("createDate").toString.replace("Some(", "").replace(")", "").toDouble
val delFlag = mapjson.get("delFlag").toString.replace("Some(", "").replace(")", "")
val deviceId = mapjson.get("deviceId").toString.replace("Some(", "").replace(")", "")
val happenTime = mapjson.get("happenTime").toString.replace("Some(", "").replace(")", "").toDouble
val isNewRecord = mapjson.get("isNewRecord").toString.replace("Some(", "").replace(")", "").toBoolean
val page = mapjson.get("page").toString.replace("Some(", "").replace(")", "")
val producerCode = mapjson.get("producerCode").toString.replace("Some(", "").replace(")", "")
val sqlMap = mapjson.get("sqlMap").toString.replace("Some(", "").replace(")", "")
println(alarmEventId)
val strings: Apple = Apple(alarmContent, alarmEventId, alarmLevel,
alarmType, buildingId, chargesCode, createDate, delFlag,
deviceId, happenTime, isNewRecord, page, producerCode, sqlMap)
val apples: Seq[ Apple ] = Seq(strings)
//println("走到这里了!")
println("logs:" + apples)
// val appRdd: RDD[ Apple ] = sc.makeRDD(apples)
/* value1.foreachPartition(iter =>{
import spark.implicits._
val frameDF: DataFrame = value1.toDF()
frameDF.createTempView("t_1")
frameDF.show()
})*/
val value1: RDD[ Apple ] = sc.parallelize(apples)
import spark.implicits._
val frameDF: DataFrame = value1.toDF()
frameDF.createTempView("t_1")
frameDF.show()
}).print()