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 @@ -1536,12 +1536,12 @@ def session_window(
1536
1536
) -> SessionWindowDefinition :
1537
1537
"""
1538
1538
Create a session window transformation on this StreamingDataFrame.
1539
-
1539
+
1540
1540
Session windows group events that occur within a specified timeout period.
1541
1541
A session starts with the first event and extends each time a new event arrives
1542
1542
within the timeout period. The session closes after the timeout period with no
1543
1543
new events.
1544
-
1544
+
1545
1545
Unlike fixed-time windows, session windows have dynamic durations based on the
1546
1546
actual events and their timing, making them ideal for user activity tracking,
1547
1547
fraud detection, and other event-driven scenarios.
Original file line number Diff line number Diff line change @@ -539,13 +539,13 @@ def _get_name(self, func_name: Optional[str]) -> str:
539
539
class SessionWindowDefinition (WindowDefinition ):
540
540
"""
541
541
Definition for session windows that group events by activity sessions.
542
-
542
+
543
543
Session windows group events that occur within a specified timeout period.
544
544
A session starts with the first event and extends each time a new event arrives
545
545
within the timeout period. The session closes after the timeout period with no
546
546
new events.
547
547
"""
548
-
548
+
549
549
def __init__ (
550
550
self ,
551
551
timeout_ms : int ,
@@ -589,7 +589,8 @@ def _create_window(
589
589
) -> SessionWindow :
590
590
if func_name :
591
591
window_type : Union [
592
- type [SessionWindowSingleAggregation ], type [SessionWindowMultiAggregation ]
592
+ type [SessionWindowSingleAggregation ],
593
+ type [SessionWindowMultiAggregation ],
593
594
] = SessionWindowSingleAggregation
594
595
else :
595
596
window_type = SessionWindowMultiAggregation
You can’t perform that action at this time.
0 commit comments