فهرست منبع

feat:修改hour的处理

zhaohaipeng 2 ماه پیش
والد
کامیت
9e5b5a626b

+ 2 - 2
src/main/java/examples/extractor/ExtractorUtils.java

@@ -192,10 +192,10 @@ public class ExtractorUtils {
     public static int getHourByTimestamp(long timestamp) {
         return LocalDateTime
                 .ofInstant(Instant.ofEpochSecond(timestamp), ZoneId.systemDefault())
-                .getHour();
+                .getHour() + 1;
     }
 
-    public static int getDayOrWeekByTimestamp(long timestamp) {
+    public static int getDayOfWeekByTimestamp(long timestamp) {
         return LocalDateTime
                 .ofInstant(Instant.ofEpochSecond(timestamp), ZoneId.systemDefault())
                 .getDayOfWeek()

+ 2 - 3
src/main/java/examples/extractor/v20250218/ExtractFeature20250218.java

@@ -96,9 +96,8 @@ public class ExtractFeature20250218 {
             featureMap.put("is_greeting", 1);
         }
 
-        LocalDateTime now = LocalDateTime.ofInstant(Instant.ofEpochSecond(ts), ZoneId.systemDefault());
-        featureMap.put("hour", now.getHour() + 1);
-        featureMap.put("day_of_week", now.getDayOfWeek().getValue());
+        featureMap.put("hour", ExtractorUtils.getHourByTimestamp(ts));
+        featureMap.put("day_of_week", ExtractorUtils.getDayOfWeekByTimestamp(ts));
 
         long createTs = Long.parseLong(videoFeature.getOrDefault("gmt_create_timestamp", "0").toString());
         featureMap.put("create_ts_diff", ExtractorUtils.getDaysBetween(createTs, ts));

+ 1 - 1
src/main/scala/com/aliyun/odps/spark/examples/makedata_recsys/makedata_recsys_41_originData_20250218.scala

@@ -148,7 +148,7 @@ object makedata_recsys_41_originData_20250218 {
               }
             }
             logs.put("hour", ExtractorUtils.getHourByTimestamp(ts))
-            logs.put("day_of_week", ExtractorUtils.getDayOrWeekByTimestamp(ts))
+            logs.put("day_of_week", ExtractorUtils.getDayOfWeekByTimestamp(ts))
 
             val logKey = logs.toString()
             val labelKey = labels.toString()