Module advanced_analytics

Advanced analytics for RS2 streams

Provides time-based windowed aggregations and advanced stream joins for building sophisticated real-time analytics.

Structs

TimeJoinConfig

Configuration for time-windowed joins

TimeWindow

A time-based window of events

TimeWindowConfig

Configuration for time-based windowing

Traits

AdvancedAnalyticsExt

Extension trait for advanced analytics

Functions

join_with_time_window

Join two streams with time-based windowing If key_selector is provided, only join on matching keys; otherwise, cross join within the window.

window_by_time

Create time-based windows from a stream of timestamped events