一种是dataframe,一组静态数据,并写入Avro格式的.Now。此比较从Avro读回,并检查具有时间戳列的比较是否失败,因为Avro存储的数据为Long,而sql类型转换提供了不同的值。**--CREATE THE DATAFRAME**
val data = Seq(Row("1",java.sql.Timestamp.valueOf("2019-03-15 18:20:06.456(spark.sparkContext.parallelize(data),StructType(schemaOrig))