个人记录

src/main/scala/com/aliyun/odps/spark/examples/makedata/makedata_17_bucketDataPrint_20240617.scala

@@ -337,14 +337,14 @@ object makedata_17_bucketDataPrint_20240617 {
 //      println("路径不合法，无法写入:" + saveV2)
 //    }
 
-    val saveV3 = "/dw/recommend/model/17_for_check_v3/" + readDate
-    if (saveV3.nonEmpty && saveV3.startsWith("/dw/recommend/model/")) {
-      println("删除路径并开始数据写入:" + saveV3)
-      MyHdfsUtils.delete_hdfs_path(saveV3)
-      data2.map(r => r._1 + "\t" + r._4.mkString("\t")).saveAsTextFile(saveV3, classOf[GzipCodec])
-    } else {
-      println("路径不合法，无法写入:" + saveV3)
-    }
+//    val saveV3 = "/dw/recommend/model/17_for_check_v3/" + readDate
+//    if (saveV3.nonEmpty && saveV3.startsWith("/dw/recommend/model/")) {
+//      println("删除路径并开始数据写入:" + saveV3)
+//      MyHdfsUtils.delete_hdfs_path(saveV3)
+//      data2.map(r => r._1 + "\t" + r._4.mkString("\t")).saveAsTextFile(saveV3, classOf[GzipCodec])
+//    } else {
+//      println("路径不合法，无法写入:" + saveV3)
+//    }
 
     val saveV4 = "/dw/recommend/model/17_for_check_v4/" + readDate
     if (saveV4.nonEmpty && saveV4.startsWith("/dw/recommend/model/")) {