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(
14941494 ) -> SessionWindowDefinition :
14951495 """
14961496 Create a session window transformation on this StreamingDataFrame.
1497-
1497+
14981498 Session windows group events that occur within a specified timeout period.
14991499 A session starts with the first event and extends each time a new event arrives
15001500 within the timeout period. The session closes after the timeout period with no
15011501 new events.
1502-
1502+
15031503 Unlike fixed-time windows, session windows have dynamic durations based on the
15041504 actual events and their timing, making them ideal for user activity tracking,
15051505 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:
537537class SessionWindowDefinition (WindowDefinition ):
538538 """
539539 Definition for session windows that group events by activity sessions.
540-
540+
541541 Session windows group events that occur within a specified timeout period.
542542 A session starts with the first event and extends each time a new event arrives
543543 within the timeout period. The session closes after the timeout period with no
544544 new events.
545545 """
546-
546+
547547 def __init__ (
548548 self ,
549549 timeout_ms : int ,
@@ -587,7 +587,8 @@ def _create_window(
587587 ) -> SessionWindow :
588588 if func_name :
589589 window_type : Union [
590- type [SessionWindowSingleAggregation ], type [SessionWindowMultiAggregation ]
590+ type [SessionWindowSingleAggregation ],
591+ type [SessionWindowMultiAggregation ],
591592 ] = SessionWindowSingleAggregation
592593 else :
593594 window_type = SessionWindowMultiAggregation
You can’t perform that action at this time.
0 commit comments