Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- val channelChangesAgg = tunerDataJsonDF
- .withWatermark("ts2", "10 seconds")
- .groupBy(window(col("ts2"),"10 seconds"),
- col("env"),
- col("servicegroupid"))
- .agg(count("linetransactionid") as "count1")
Add Comment
Please, Sign In to add comment
