Commit f912b453 authored by litaolemo's avatar litaolemo

update

parent 98c206ca
...@@ -132,8 +132,8 @@ for t in range(1, task_days): ...@@ -132,8 +132,8 @@ for t in range(1, task_days):
print(sql_dev_device_id) print(sql_dev_device_id)
dev_df = spark.sql(sql_dev_device_id) dev_df = spark.sql(sql_dev_device_id)
dev_df_view = dev_df.createOrReplaceTempView("dev_view") dev_df_view = dev_df.createOrReplaceTempView("dev_view")
dev_df_view.show(1) dev_df.show(1)
sql_res = dev_df_view.collect() sql_res = dev_df.collect()
for res in sql_res: for res in sql_res:
print(res) print(res)
......
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