Hi,

We receive bursts of data with sequential ids and I would like to find the
range for each burst-window.  What's the best way to find the "window"
ranges in Spark?

Input
-------
1
2
3
4
6
7
8
100
101
102
500
700
701
702
703
704

Output (window start, window end)
------------------------------------------------
1, 4
6, 8
100, 102
500, 500
700, 704

Reply via email to