Browse Source

add time feature

jch 5 months ago
parent
commit
1e8afbb006

+ 8 - 7
src/main/scala/com/aliyun/odps/spark/examples/makedata_recsys_r_rate/makedata_recsys_61_originData_20241209.scala

@@ -432,13 +432,14 @@ object makedata_recsys_61_originData_20241209 {
   }
 
   def tsToCalendar(ts: String): Calendar = {
-    val ms = ts.toLong * 1000L
-    if (ms > 1107658247000L && ms < 2685495047000L) {
-      val calendar = Calendar.getInstance
-      calendar.setTimeInMillis(ms)
-      calendar
-    } else {
-      null
+    if (null != ts && ts.nonEmpty) {
+      val ms = ts.toLong * 1000L
+      if (ms > 1107658247000L && ms < 2685495047000L) {
+        val calendar = Calendar.getInstance
+        calendar.setTimeInMillis(ms)
+        return calendar
+      }
     }
+    null
   }
 }

+ 8 - 7
src/main/scala/com/aliyun/odps/spark/examples/makedata_recsys_r_rate/makedata_recsys_72_originData_20250109.scala

@@ -479,13 +479,14 @@ object makedata_recsys_72_originData_20250109 {
   }
 
   def tsToCalendar(ts: String): Calendar = {
-    val ms = ts.toLong * 1000L
-    if (ms > 1107658247000L && ms < 2685495047000L) {
-      val calendar = Calendar.getInstance
-      calendar.setTimeInMillis(ms)
-      calendar
-    } else {
-      null
+    if (null != ts && ts.nonEmpty) {
+      val ms = ts.toLong * 1000L
+      if (ms > 1107658247000L && ms < 2685495047000L) {
+        val calendar = Calendar.getInstance
+        calendar.setTimeInMillis(ms)
+        return calendar
+      }
     }
+    null
   }
 }