Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- udf_parse_time = udf(parse_clf_time)
- logs_df = (logs_df.select('*', udf_parse_time(logs_df['timestamp'])
- .cast('timestamp')
- .alias('time'))
- .drop('timestamp')
- logs_df.show(10, truncate=True)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement