Would be amazing if the sliding window function from this Data Engineering Weekly article could be included in the codebase as (something like) pw.sliding_window(...)
def sliding_window(log_table, ts_table, length):
t_sliding_window = log_table.filter(
pw.this.ts >= ts_table.ix_ref().ts - length
)
return t_sliding_window