Skip to content

Commit 0ab8812

Browse files
committed
Correct docs
1 parent 798a431 commit 0ab8812

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

docs/windowing.md

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@ With windows, you can calculate such aggregations as:
99
- Total of website visitors for every hour
1010
- The average speed of a vehicle over the last 10 minutes
1111
- Maximum temperature of a sensor observed over 30 second ranges
12-
- Give an user a reward after 10 succesful actions
12+
- Give a user a reward after 10 successful actions
1313
- Track user activity sessions on a website
1414
- Detect fraud patterns in financial transactions
1515

@@ -205,14 +205,14 @@ Count-based Tumbling Windows slice incoming events into batch of a fixed size.
205205
For example, a tumbling window configured with a count of 4 will batch and aggregate message 1 to 4, then 5 to 8, 9 to 12 and so on.
206206

207207
```
208-
Count Tumbing Windows
208+
Count Tumbling Windows
209209
[0, 3] : ....
210210
[4, 7] : ....
211211
[8, 11] : ....
212212
[12, 15] : ....
213213
```
214214

215-
In a tumbing window each message is only assigned to a **single** interval.
215+
In a tumbling window each message is only assigned to a **single** interval.
216216

217217
**Example**
218218

@@ -358,7 +358,7 @@ Count Hopping Windows
358358
[6, 11] : ......
359359
```
360360

361-
In hopping windows each messages can be assigned to multiple windows because the windows overlap.
361+
In hopping windows each message can be assigned to multiple windows because the windows overlap.
362362

363363
## Time-based Sliding Windows
364364
Sliding windows are overlapping time-based windows that advance with each incoming message, rather than at fixed time intervals like hopping windows. They have a fixed 1 ms resolution and perform better and are less resource-intensive than hopping windows with a 1 ms step. Sliding windows do not produce redundant windows; every interval has a distinct aggregation.
@@ -440,7 +440,7 @@ sdf = (
440440

441441
Sliding windows are overlapping windows that advance with each incoming message. They are equal to count-based hopping windows with a step of 1.
442442

443-
For example a sliding window of 4 messagew will generate the followiwng windows:
443+
For example a sliding window of 4 messages will generate the following windows:
444444

445445
```
446446
Count Sliding Windows
@@ -504,7 +504,7 @@ sdf = (
504504

505505
## Session Windows
506506

507-
Session windows group events that occur within a specified timeout period. Unlike fixed-time windows (tumbling, hopping, sliding), session windows have dynamic durations based on the actual timing of events, making them ideal for user activity tracking, fraud detection, and other event-driven scenarios.
507+
Session windows group events that occur within a specified timeout period. Unlike fixed-time windows (tumbling, hopping, sliding), session windows have dynamic durations based on the actual timing of events. This makes them ideal for user activity tracking, fraud detection, and other event-driven scenarios.
508508

509509
A session starts with the first event and extends each time a new event arrives within the timeout period. The session closes after the timeout period with no new events.
510510

@@ -525,7 +525,7 @@ Timeout: 10 seconds
525525
Grace: 2 seconds
526526
527527
Session 1: [0, 20] - Events A, B (B extends the session from A)
528-
Session 2: [25, 35] - Events C, D (D extends the session from C)
528+
Session 2: [25, 40] - Events C, D (D extends the session from C)
529529
Session 3: [45, 55] - Event E (session will close at 55 if no more events)
530530
```
531531

@@ -914,7 +914,7 @@ sdf = sdf.tumbling_window(timedelta(seconds=10)).agg(value=Sum()).final(closing_
914914
An alternative is to use the **partition** closing strategy.
915915
In this strategy, messages advance time and close windows for the whole partition to which this key belongs.
916916

917-
If messages aren't ordered accross keys some message can be skipped if the windows are already closed.
917+
If messages aren't ordered across keys some message can be skipped if the windows are already closed.
918918

919919
```python
920920
from datetime import timedelta

0 commit comments

Comments
 (0)