需求說明 : 如下為某直播平臺主播開播及關播時間，根據該資料計算出平臺最高峰同時線上的主播

-- 資料準備

-- DDL
create table test8 (
`id` string comment '主播id',
`stt` string comment '主播登入時間',
`edt` string comment '主播登出時間')
 comment '主播登入記錄表'
row format delimited fields terminated by '\t'
lines terminated by '\n' stored as orc;


insert overwrite table
 
 test8
select '1001', '2021-06-14 12:12:12', '2021-06-14 18:12:12' union all
select '1003', '2021-06-14 13:12:12', '2021-06-14 16:12:12' union all
select '1004', '2021-06-14 13:15:12', '2021-06-14 20:12:12' union all
select '1002', '2021-06-14 15:12:12', '2021-06-14 16:12:12' union all
select '1005', '2021-06-14 15:18:12', '2021-06-14 20:12:12
 
' union all
select '1001', '2021-06-14 20:12:12', '2021-06-14 23:12:12' union all
select '1006', '2021-06-14 21:12:12', '2021-06-14 23:15:12' union all
select '1007', '2021-06-14 22:12:12', '2021-06-14 23:10:12' union all
select '1008', '2021-06-14 11:12:12', '2021-06-14 19:10:12' ;

說明 : 如下為某直播平臺主播開播及關播時間，根據該資料計算出平臺最高峰同時線上的主播人數
 

方案1 :

1. 思路分析
    1. 每條資料與本表自關聯(笛卡爾積)
    2. 篩選出 同時線上的資料
        同時線上的條件 :
            1001 1----------5
              2-----------6
                 t1.stt <= t2.edt
            and  t1.edt >= t2.stt

-- 查詢sql
select
t1.id
,t1.stt
,t1.edt
,count(distinct t2.id) as cnt
from test8 as t1
left outer join test8 as t2
where t1.stt <= t2.edt
and   t1.edt >= t2.stt
group by t1.id
,t1.stt
,t1.edt
;

-- 查詢結果
t1.id   t1.stt                  t1.edt                  cnt
1001    2021-06-14 12:12:12     2021-06-14 18:12:12     6
1001    2021-06-14 20:12:12     2021-06-14 23:12:12     5
1002    2021-06-14 15:12:12     2021-06-14 16:12:12     6
1003    2021-06-14 13:12:12     2021-06-14 16:12:12     6
1004    2021-06-14 13:15:12     2021-06-14 20:12:12     6
1005    2021-06-14 15:18:12     2021-06-14 20:12:12     6
1006    2021-06-14 21:12:12     2021-06-14 23:15:12     3
1007    2021-06-14 22:12:12     2021-06-14 23:10:12     3
1008    2021-06-14 11:12:12     2021-06-14 19:10:12     6

方案2 :

1-----3
  2-----4
          5----6
             7-----8

1 1
2 1
3 -1
4 -1
5 1
6 -1
7 1
8 -1


-- 查詢sql

with t1 as (
    select id
         , stt as ds
         , 1   as login_flag
    from test8
    union all
    select id
         , edt as ds
         , -1  as login_flag
    from test8
)
select
id
,ds
,login_flag
,sum(login_flag) over(order by ds) as sum_login
from t1
;

-- 查詢結果
id      ds                  login_flag sum_login
1008    2021-06-14 11:12:12     1       1
1001    2021-06-14 12:12:12     1       2
1003    2021-06-14 13:12:12     1       3
1004    2021-06-14 13:15:12     1       4
1002    2021-06-14 15:12:12     1       5
1005    2021-06-14 15:18:12     1       6
1002    2021-06-14 16:12:12     -1      4
1003    2021-06-14 16:12:12     -1      4
1001    2021-06-14 18:12:12     -1      3
1008    2021-06-14 19:10:12     -1      2
1001    2021-06-14 20:12:12     1       1
1005    2021-06-14 20:12:12     -1      1
1004    2021-06-14 20:12:12     -1      1
1006    2021-06-14 21:12:12     1       2
1007    2021-06-14 22:12:12     1       3
1007    2021-06-14 23:10:12     -1      2
1001    2021-06-14 23:12:12     -1      1
1006    2021-06-14 23:15:12     -1      0

方案3(實時) :
開啟變數 login_cnt 為線上人數
    新登使用者 + 1
    退出使用者 - 1