Kaynağa Gözat

从hive输入到hive输出

xueyiming 2 ay önce
ebeveyn
işleme
bbd6d789d2

+ 1 - 1
src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/v20240718/makedata_ad_31_originData_hive_20240718.scala

@@ -64,7 +64,7 @@ object makedata_ad_31_originData_hive_20240718 {
     // 3 循环执行数据生产
     val dateRange = MyDateUtils.getDateRange(beginStr, endStr)
     for (dt <- dateRange) {
-      val timeRange = MyDateUtils.getDateHourRange(dt + "06", dt + "23")
+      val timeRange = MyDateUtils.getDateHourRange(dt + "08", dt + "23")
       val list = timeRange.map { dt_hh =>
           val dt = dt_hh.substring(0, 8)
           val hh = dt_hh.substring(8, 10)