Commit 772f5536 authored by 张彦钊's avatar 张彦钊

add

parent 64f80e25
......@@ -36,7 +36,7 @@ if __name__ == '__main__':
spark = SparkSession.builder.config(conf=sparkConf).enableHiveSupport().getOrCreate()
sql = "select params['exposure_cards'] from online.ml_community_precise_exposure_detail " \
"where action = 'page_precise_exposure' and page_name = 'search_result_welfare' " \
"AND partition_date='20190926' limit 20"
"AND partition_date='20190926'"
df = spark.sql(sql)
# # df.show(6)
# # params['exposure_cards'],
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment