diff数据

src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/v20240718/diff_data_20250422.scala

@@ -27,13 +27,13 @@ object diff_data_20250422 {
     val odpsOps = env.getODPS(sc)
     val odpsData1 = odpsOps.readTable(project = "loghubods",
       table = "ad_easyrec_train_data_v3_sampled",
-      partition = "dt=20250421",
+      partition = "dt=20250422",
       transfer = func,
       numPartition = 64)
 
     val odpsData2 = odpsOps.readTable(project = "loghubods",
       table = "ad_engine_statistics_log_per_linshi_dt",
-      partition = "dt=20250421",
+      partition = "dt=20250422",
       transfer = func1,
       numPartition = 64).map(record => {
       val pqtid = record.getString("pqtid")