Przeglądaj źródła

增加diff校验

xueyiming 1 miesiąc temu
rodzic
commit
c1d9573f75

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

@@ -30,7 +30,7 @@ object diff_data_20250319 {
 
     val odpsData2 = odpsOps.readTable(project = "loghubods",
       table = "alg_recsys_ad_sample_all",
-      partition = "dt=20250319",
+      partition = "dt=20250319,hh=12",
       transfer = func,
       numPartition = 64)