Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- mainDataset = mainDataset.groupBy(
- col("session_id"),
- window(col("datetime"), "20 minutes"))
- .agg(collect_set(
- col("term"))
- .as("termlist"));
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement