统计like项目

eda/feededa/src/main/scala/com/gmei/temp_analysis.scala

@@ -590,11 +590,11 @@ object alpha_ctr {
            |and type = 'page_precise_exposure'
            |and partition_day='${partition_date}'
        """.stripMargin
-      ).show()
-//        .rdd.map(row => {
-//        val lenth=row.toSeq.length
-//        (stat_date,lenth)
-//      }).toDF("stat_date","count").show()
+      )
+        .rdd.map(row => {
+        val lenth=JSON.parseFull(row.toString())
+        (stat_date,lenth)
+      }).toDF("stat_date","count").show()
         /*.rdd
         .map(row =>{
         val s = row.getAs[List[String]]("exposure_cards")