From 04b2408d1b985a59c463295c30131a9ee09754a6 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=8E=8B=E5=BF=97=E4=BC=9F?= <wangzhiwei@igengmei.com>
Date: Wed, 5 Dec 2018 15:08:30 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E7=BB=9F=E8=AE=A1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../src/main/scala/com/gmei/testt.scala | 29 ++++++++++---------
1 file changed, 16 insertions(+), 13 deletions(-)
diff --git a/eda/feededa/src/main/scala/com/gmei/testt.scala b/eda/feededa/src/main/scala/com/gmei/testt.scala
index 4f77fe17..668b23c1 100644
--- a/eda/feededa/src/main/scala/com/gmei/testt.scala
+++ b/eda/feededa/src/main/scala/com/gmei/testt.scala
@@ -65,20 +65,23 @@ object testt {
// )
//// agency_id.show()
// agency_id.createOrReplaceTempView("agency_id")
+ val a = Array("message_home","my_favor","my_order","order_detail","organization_detail","other_homepage")
+ for (i <- 0 until a.length){
+ val diary_pv = sc.sql(
+ s"""
+ |select partition_date,count(cl_id)
+ |from online.tl_hdfs_maidian_view
+ |where action="page_view"
+ |and params["page_name"]="diary_detail"
+ |and params["referrer"]='${a(i)}'
+ |and partition_date >='20181120'
+ |GROUP BY partition_date
+ |order by partition_date
+ """.stripMargin
+ )
+ diary_pv.show()
+ }
- val diary_pv = sc.sql(
- s"""
- |select partition_date,count(cl_id)
- |from online.tl_hdfs_maidian_view
- |where action="page_view"
- |and params["page_name"]="diary_detail"
- |and params["referrer"]='hospital_all_cases'
- |and partition_date >='20181120'
- |GROUP BY partition_date
- |order by partition_date
- """.stripMargin
- )
- diary_pv.show()
// GmeiConfig.writeToJDBCTable(view_count, "avg", SaveMode.Overwrite)
--
2.18.0