Skip to content

M
meta_base_code
Commit c60422b2 authored by litaolemo's avatar litaolemo
Browse files
Options

update

parent 68d39815
Hide whitespace changes
Inline Side-by-side
Showing with 1 addition and 2 deletions
task/search_strategy_d.py
View file @ c60422b2
...@@ -74,9 +74,8 @@ for t in range(0, task_days): ...@@ -74,9 +74,8 @@ for t in range(0, task_days):
sql_distinct_device_id = r""" sql_distinct_device_id = r"""
SELECT distinct user_id SELECT distinct user_id
FROM online.tl_hdfs_doctor_view FROM online.tl_hdfs_doctor_view
WHERE partition_date = '{yesterday_str}'
""".format(today_str=today_str, yesterday_str=yesterday_str) """
print(sql_distinct_device_id) print(sql_distinct_device_id)
distinct_device_id_df = spark.sql(sql_distinct_device_id) distinct_device_id_df = spark.sql(sql_distinct_device_id)
# distinct_device_id_df.show(20) # distinct_device_id_df.show(20)
......
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