feat:修改工具类

src/main/scala/com/aliyun/odps/spark/examples/myUtils/DataTimeUtil.java → src/main/java/examples/utils/DateTimeUtil.java

@@ -1,10 +1,10 @@
-package com.aliyun.odps.spark.examples.myUtils;
+package examples.utils;
 
 import java.time.Instant;
 import java.time.LocalDateTime;
 import java.time.ZoneId;
 
-public class DataTimeUtil {
+public class DateTimeUtil {
 
     public static int getHourByTimestamp(long timestamp) {
         return LocalDateTime
@@ -19,3 +19,4 @@ public class DataTimeUtil {
                 .getValue();
     }
 }
+

src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/makedata_ad_31_originData_20240718.scala

@@ -5,6 +5,7 @@ import com.aliyun.odps.TableSchema
 import com.aliyun.odps.data.Record
 import com.aliyun.odps.spark.examples.myUtils.{DataTimeUtil, MyDateUtils, MyHdfsUtils, ParamUtils, env}
 import examples.extractor.RankExtractorFeature_20240530
+import examples.utils.DateTimeUtil
 import org.apache.hadoop.io.compress.GzipCodec
 import org.apache.spark.sql.SparkSession
 import org.xm.Similarity
@@ -92,10 +93,10 @@ object makedata_ad_31_originData_20240718 {
               featureMap.put("targeting_conversion_" + b1.getString("targeting_conversion"), idDefaultValue)
             }
 
-            val hour = DataTimeUtil.getHourByTimestamp(ts)
+            val hour = DateTimeUtil.getHourByTimestamp(ts)
             featureMap.put("hour_" + hour, 0.1)
 
-            val dayOfWeek = DataTimeUtil.getDayOrWeekByTimestamp(ts)
+            val dayOfWeek = DateTimeUtil.getDayOrWeekByTimestamp(ts)
             featureMap.put("dayOfWeek_" + dayOfWeek, 0.1);
 
             if (b1.containsKey("cpa")) {