跳到主要内容
跳到主要内容

WINDOW-FUNCTION-WINDOW-FUNNEL

WINDOW FUNCTION WINDOW_FUNNEL

description

漏斗分析函数搜索滑动时间窗口内最大的发生的最大事件序列长度。

  • window :滑动时间窗口大小,单位为秒。
  • mode :保留,目前只支持default。
  • timestamp_column :指定时间列,类型为DATETIME, 滑动窗口沿着此列工作。
  • eventN :表示事件的布尔表达式。

漏斗分析函数按照如下算法工作:

  • 搜索到满足满足条件的第一个事件,设置事件长度为1,此时开始滑动时间窗口计时。
  • 如果事件在时间窗口内按照指定的顺序发生,时间长度累计增加。如果事件没有按照指定的顺序发生,时间长度不增加。
  • 如果搜索到多个事件链,漏斗分析函数返回最大的长度。
window_funnel(window, mode, timestamp_column, event1, event2, ... , eventN)

example

CREATE TABLE windowfunnel_test (
`xwho` varchar(50) NULL COMMENT 'xwho',
`xwhen` datetime COMMENT 'xwhen',
`xwhat` int NULL COMMENT 'xwhat'
)
DUPLICATE KEY(xwho)
DISTRIBUTED BY HASH(xwho) BUCKETS 3
PROPERTIES (
"replication_num" = "1"
);

INSERT into windowfunnel_test (xwho, xwhen, xwhat) values ('1', '2022-03-12 10:41:00', 1),
('1', '2022-03-12 13:28:02', 2),
('1', '2022-03-12 16:15:01', 3),
('1', '2022-03-12 19:05:04', 4);

select window_funnel(3600 * 3, 'default', t.xwhen, t.xwhat = 1, t.xwhat = 2 ) AS level from windowfunnel_test t;

| level |
|---|
| 2 |

keywords

WINDOW,FUNCTION,WINDOW_FUNNEL