场景

• 房间故障统计 统计房间故障，故障包括卡顿、丢帧、音视频不同步信息，使用10分钟一个窗口进行统计。

SELECT
    CAST(TUMBLE_START(proctime, INTERVAL '10' MINUTE) asVARCHAR) as app_ts,
    roomid,
    SUM(ublock) as ublock, --统计10分钟内上行卡顿次数
    SUM(dblock) as dblock, --统计10分钟内下行卡顿次数
    SUM(adrop) as adrop, --统计10分钟内音频丢包次数
    SUM(vdrop) as vdrop, --统计10分钟内视频丢包次数
    SUM(alat) as alat, --统计10分钟内音频延迟
    SUM(vlat) as vlat, --统计10分钟内音频延迟
FROM
    view_app_heartbeat_Stream
GROUPBY
    TUMBLE(proctime, INTERVAL '10' MINUTE), roomid

• 分地域统计延迟情况 分地域统计数据端到端延迟平均情况，每10分钟统计音频、视频平均延迟情况。

SELECT
    CAST(TUMBLE_START(proctime, INTERVAL '10' MINUTE) asVARCHAR) as app_ts,
    region,
    SUM(alat)/COUNT(alat) as alat,
    SUM(vlat)/COUNT(vlat) as vlat,
FROM
    view_app_heartbeat_Stream
GROUPBY
    TUMBLE(proctime, INTERVAL '10' MINUTE), region;

• 实时整体卡顿率 统计实时整体卡顿率，即出现卡顿的在线用户数/在线总用户数*100%，通过此指标可以衡量当前卡顿影响的人群范围。

SELECT
    CAST(TUMBLE_START(proctime, INTERVAL '10' MINUTE) asVARCHAR) as app_ts,
    SUM(IF(ublock <> 0 OR dblock <> 0, 1, 0)) / CAST(COUNT(DISTINCT userid) ASDOUBLE) as block_rate, 
FROM
    view_app_heartbeat_Stream
GROUPBY
    TUMBLE(proctime, INTERVAL '10' MINUTE);