File tree Expand file tree Collapse file tree 2 files changed +6
-5
lines changed Expand file tree Collapse file tree 2 files changed +6
-5
lines changed Original file line number Diff line number Diff line change @@ -1494,12 +1494,12 @@ def session_window(
1494
1494
) -> SessionWindowDefinition :
1495
1495
"""
1496
1496
Create a session window transformation on this StreamingDataFrame.
1497
-
1497
+
1498
1498
Session windows group events that occur within a specified timeout period.
1499
1499
A session starts with the first event and extends each time a new event arrives
1500
1500
within the timeout period. The session closes after the timeout period with no
1501
1501
new events.
1502
-
1502
+
1503
1503
Unlike fixed-time windows, session windows have dynamic durations based on the
1504
1504
actual events and their timing, making them ideal for user activity tracking,
1505
1505
fraud detection, and other event-driven scenarios.
Original file line number Diff line number Diff line change @@ -537,13 +537,13 @@ def _get_name(self, func_name: Optional[str]) -> str:
537
537
class SessionWindowDefinition (WindowDefinition ):
538
538
"""
539
539
Definition for session windows that group events by activity sessions.
540
-
540
+
541
541
Session windows group events that occur within a specified timeout period.
542
542
A session starts with the first event and extends each time a new event arrives
543
543
within the timeout period. The session closes after the timeout period with no
544
544
new events.
545
545
"""
546
-
546
+
547
547
def __init__ (
548
548
self ,
549
549
timeout_ms : int ,
@@ -587,7 +587,8 @@ def _create_window(
587
587
) -> SessionWindow :
588
588
if func_name :
589
589
window_type : Union [
590
- type [SessionWindowSingleAggregation ], type [SessionWindowMultiAggregation ]
590
+ type [SessionWindowSingleAggregation ],
591
+ type [SessionWindowMultiAggregation ],
591
592
] = SessionWindowSingleAggregation
592
593
else :
593
594
window_type = SessionWindowMultiAggregation
You can’t perform that action at this time.
0 commit comments