val json:JSONObject = JSON.parseObject(jsonMsg:String)

val message:String = json.getString("message")

val student:Student = JSON.parseObject[Student](json:String, classOf[Student])

import scala.collection.JavaConverters._

val javaList = JSON.parseArray[ColumnValue](columnList, classOf[ColumnValue])

val colValueList = javaList.asScala

<dependency>

     <groupId>com.alibaba</groupId>

     <artifactId>fastjson</artifactId>

     <version>1.2.</version>

</dependency>

import org.apache.commons.lang.time.FastDateFormat

val yearMonthDayHour：String = FastDateFormat.getInstance("yyyyMMddHH").format(timeStamp：Long)

Math.max(element.timeStamp, preiodicTimeStamp)

import org.json4s.DefaultFormats
import org.json4s.native.Serialization.write

val value: DataStream[Student]
val DataStreamStr: DataStream[String] = value.map {

      //进行json格式转换

      log => {

        //导入隐式转换

        implicit val formats = DefaultFormats

        val str = write(log)

        str

      }

    }