Advertisement
Guest User

Untitled

a guest
Apr 19th, 2019
90
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.27 KB | None | 0 0
  1. udf_parse_time = udf(parse_clf_time)
  2.  
  3. logs_df = (logs_df.select('*', udf_parse_time(logs_df['timestamp'])
  4. .cast('timestamp')
  5. .alias('time'))
  6. .drop('timestamp')
  7. logs_df.show(10, truncate=True)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement