|
@@ -56,12 +56,12 @@ object diff_data_20250422 {
|
|
|
|
|
|
// val rdd1: JSONObject = odpsData1.first()
|
|
// val rdd1: JSONObject = odpsData1.first()
|
|
println("rdd1")
|
|
println("rdd1")
|
|
- println(rdd1.get("logkey").toString)
|
|
|
|
|
|
+ println(rdd1.get("pqtid").toString)
|
|
println(rdd1.toString)
|
|
println(rdd1.toString)
|
|
|
|
|
|
// val rdd2: JSONObject = odpsData2.first()
|
|
// val rdd2: JSONObject = odpsData2.first()
|
|
println("rdd2")
|
|
println("rdd2")
|
|
- println(rdd2.getString("logkey"))
|
|
|
|
|
|
+ println(rdd2.getString("pqtid"))
|
|
println(rdd2.toString)
|
|
println(rdd2.toString)
|
|
|
|
|
|
val keys = rdd1.keySet().asScala.toSet ++ rdd2.keySet().asScala.toSet
|
|
val keys = rdd1.keySet().asScala.toSet ++ rdd2.keySet().asScala.toSet
|