瀏覽代碼

修改生成训练数据

xueyiming 1 周之前
父節點
當前提交
5cdaa85533

+ 4 - 2
src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/v20240718/makedata_ad_33_bucketDataFromOriginToHive_20250228.scala

@@ -116,8 +116,10 @@ object makedata_ad_33_bucketDataFromOriginToHive_20250228 {
             })
             .map(record => {
               val ts = record.getString("ts").toInt
-              val zonedDateTime = ZonedDateTime.ofInstant(Instant.ofEpochMilli(ts), ZoneId.systemDefault())
-              val featureMap = new JSONObject()
+              val instant = Instant.ofEpochSecond(ts)
+              val chinaZone = ZoneId.of("Asia/Shanghai")
+              // 将 Instant 对象转换为中国时区的 ZonedDateTime 对象
+              val zonedDateTime = ZonedDateTime.ofInstant(instant, chinaZone)
               // 获取小时
               val tsHour = zonedDateTime.getHour()
               // 当前小时-刻钟(15分钟一个间隔,0~95)