Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
03-23-2022 12:51 PM
Windowing function can be what you need.
from pyspark.sql import functions as F
df.groupBy(F.window("event_time","5 minutes"))