Skip to content

C
crawler
Commit 749f0b27 authored by litaolemo's avatar litaolemo
Browse files
Options

update

parent 8a074076
Show whitespace changes
Inline Side-by-side
Showing with 1 addition and 0 deletions
tasks/from_sparksql_to_mysql.py
View file @ 749f0b27
...@@ -78,6 +78,7 @@ device_df.show(1, False) ...@@ -78,6 +78,7 @@ device_df.show(1, False)
sql_res = device_df.collect() sql_res = device_df.collect()
print("-----------------------------------------------------------------------------") print("-----------------------------------------------------------------------------")
for res in sql_res: for res in sql_res:
print(res)
day_id = res.day_id day_id = res.day_id
device_os_type = res.device_os_type device_os_type = res.device_os_type
active_type = res.active_type active_type = res.active_type
......
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