|
@@ -26,7 +26,7 @@ object diff_data_20250422 {
|
|
// 2 读取odps+表信息
|
|
// 2 读取odps+表信息
|
|
val odpsOps = env.getODPS(sc)
|
|
val odpsOps = env.getODPS(sc)
|
|
val odpsData1 = odpsOps.readTable(project = "loghubods",
|
|
val odpsData1 = odpsOps.readTable(project = "loghubods",
|
|
- table = "ad_easyrec_eval_data_v3_sampled",
|
|
|
|
|
|
+ table = "ad_easyrec_train_data_v3_sampled",
|
|
partition = "dt=20250421",
|
|
partition = "dt=20250421",
|
|
transfer = func,
|
|
transfer = func,
|
|
numPartition = 64)
|
|
numPartition = 64)
|