all

src/main/scala/com/aliyun/odps/spark/examples/makedata/makedata_02_writeredis.scala

@@ -134,14 +134,14 @@ object makedata_02_writeredis {
     val reqContext: RequestContextOffline = new RequestContextOffline()
 
     //todo 有特征不在表里 临时修复
-    record.set("i_title_len", if (record.getString("title") != null) record.getString("title").length.toString else null)
+    record.setString("i_title_len", if (record.getString("title") != null) record.getString("title").length.toString else "")
     if (record.getDatetime("gmt_create") != null){
       val format = new SimpleDateFormat("yyyyMMdd")
       val dateOld = format.format(record.getDatetime("gmt_create"))
       val dayDiff = MyDateUtils.calculateDateDifference(dateOld, date)
-      record.set("i_days_since_upload", dayDiff.toString)
+      record.setString("i_days_since_upload", dayDiff.toString)
     }else{
-      record.set("i_days_since_upload", null)
+      record.setString("i_days_since_upload", "")
     }