非常有趣的问题。这是我如何接近它的

select * from sliding

+-------------+----------------+--+
| sliding.ts  | sliding.users  |
+-------------+----------------+--+
| 100         |  A             |
| 101         |  B             |
| 101         |  A             |
| 102         |  C             |
| 103         |  A             |
| 104         |  C             |
| 104         |  A             |
| 9999        |  D             |
| 20000       |  D             |
+-------------+----------------+--+

我们现在需要计算 ts 当前行的 ts 上一行的 (lag) 或下一行 (lead) . lag(ts,1,0) 它提供了 ts 上一行的。但有一个问题，如果当前行是第一行，会发生什么？没问题，用吧 lag(ts,1,0) 这个 0 如果前面没有行，则返回默认值。
现在我们需要做的就是减去 lag 从 ts 并应用条件（您的时间窗口）。也就是说，检查电流 ts - lag_ts 在600以内。
有人可能会认为，如果前一行 ts 远高于当前行 ts ? 但不会，因为 over 子句具有 order by ts .

select users, ts, lag, lead  from (
    select users, ts, 
         lag(ts,1,0) over (order by ts) as lag, 
         lead(ts,1) over( order by ts) as lead
    from sliding ) tbl
where (ts - lag) <= 600

+--------+------+------+-------+--+
| users  |  ts  | lag  | lead  |
+--------+------+------+-------+--+
|  A     | 100  | 0    | 101   |
|  A     | 101  | 100  | 101   |
|  B     | 101  | 101  | 102   |
|  C     | 102  | 101  | 103   |
|  A     | 103  | 102  | 104   |
|  A     | 104  | 103  | 104   |
|  C     | 104  | 104  | 9999  |
+--------+------+------+-------+--+

应用distinct count gets

select count(distinct users)  from (
    select users, ts, 
         lag(ts,1,0) over (order by ts) as lag, 
         lead(ts,1) over( order by ts) as lead
    from sliding ) tbl
where (ts - lag) <= 600 

+------+--+
| _c0  |
+------+--+
| 3    |
+------+--+

我不是用户如果配置单元允许窗口有动态的边界宽度，它只支持固定的窗口宽度据我所知
但看看这是否对你有用。使用 floor 舍入最近的10分钟时间戳并做一个分析函数。

select  ts, session , count(distinct session) over (partition by floor((ts+599)/600) * 600) from your_table;

结果如下：

ts    | session | cnt
------------------------------
100   | A       | 2
201   | B       | 2
301   | A       | 2
702   | C       | 1
``` `floor((ts+599)/600) * 600)` -这使得时间戳为0-600的会话将落入一个存储桶，601-1200落入另一个存储桶，以此类推。
取决于您使用的配置单元版本**不同**部件可能/可能不起作用 `count(distinct session) over (..)`