Explorar o código

修改生成训练数据

xueyiming hai 1 semana
pai
achega
476fd2c32f

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

@@ -115,8 +115,10 @@ object makedata_ad_33_bucketDataFromOriginToHive_20250228 {
               label > 0 || Random.nextDouble() < negSampleRate
             })
             .map(record => {
+              val featureMap = new JSONObject()
               val ts = record.getString("ts").toInt
               val instant = Instant.ofEpochSecond(ts)
+              // 设置时区为中国时区
               val chinaZone = ZoneId.of("Asia/Shanghai")
               // 将 Instant 对象转换为中国时区的 ZonedDateTime 对象
               val zonedDateTime = ZonedDateTime.ofInstant(instant, chinaZone)