update

task/daily_search_word_count_last_two_year.py

@@ -128,7 +128,7 @@ tableDF1 = spark.read.format("jdbc").\
 	    option("dbtable", "wiki_item").\
 	    option("user", "work").\
 	    option("password", "BJQaT9VzDcuPBqkd").load().createOrReplaceTempView("wiki_item")
-tableDF1.show()
+
 
 tableDF2 = spark.read.format("jdbc").\
 	    option("url","jdbc:mysql://172.16.30.143/zhengxing").\
@@ -136,7 +136,7 @@ tableDF2 = spark.read.format("jdbc").\
 	    option("dbtable", "wiki_product").\
 	    option("user", "work").\
 	    option("password", "BJQaT9VzDcuPBqkd").load().createOrReplaceTempView("wiki_product")
-tableDF2.show()
+
 
 tableDF3 = spark.read.format("jdbc").\
 	    option("url","jdbc:mysql://172.16.30.143/zhengxing").\
@@ -144,7 +144,7 @@ tableDF3 = spark.read.format("jdbc").\
 	    option("dbtable", "wiki_collect").\
 	    option("user", "work").\
 	    option("password", "BJQaT9VzDcuPBqkd").load().createOrReplaceTempView("wiki_collect")
-tableDF3.show()
+
 
 tableDF4 = spark.read.format("jdbc").\
 	    option("url","jdbc:mysql://172.16.30.143/zhengxing").\
@@ -152,7 +152,7 @@ tableDF4 = spark.read.format("jdbc").\
 	    option("dbtable", "wiki_brand").\
 	    option("user", "work").\
 	    option("password", "BJQaT9VzDcuPBqkd").load().createOrReplaceTempView("wiki_brand")
-tableDF4.show()
+
 # df = spark.read.jdbc(url="jdbc:mysql://172.16.30.143/zhengxing?user=work&password=BJQaT9VzDcuPBqkd&rewriteBatchedStatements=true",table="wiki_item")
 # print(huidu_device_id_sql)
 # huidu_device_id_df = spark.sql(huidu_device_id_sql)