Advertisement
Guest User

Untitled

a guest
Apr 20th, 2019
101
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.14 KB | None | 0 0
  1. mainDataset = mainDataset.groupBy(
  2. col("session_id"),
  3. window(col("datetime"), "20 minutes"))
  4. .agg(collect_set(
  5. col("term"))
  6. .as("termlist"));
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement