如何在Druid中应用窗口函数？LEAD函数报错求助

Druid 支持窗口函数（包括LEAD），你遇到的No match found for function signature LEAD(<CHARACTER>)错误，是因为Druid的LEAD函数仅支持数值类型参数，而你传入的event_type是字符串类型，导致函数签名不匹配。

直接修复方案 #

将字符串类型的event_type转换为可排序的数值标识，使用LEAD处理数值后再映射回原字符串：

WITH event_mapped AS (
  SELECT 
    user_id,
    event_timestamp,
    event_type,
    -- 给每个事件类型分配唯一数值ID
    CASE event_type
      WHEN 'media_play' THEN 1
      WHEN 'recommendation_hit' THEN 2
      -- 按需补充其他事件类型的映射
    END AS event_num
  FROM your_dataset
)
SELECT
  user_id,
  event_timestamp,
  event_type,
  -- 将LEAD返回的数值映射回事件类型字符串
  CASE LEAD(event_num) OVER (PARTITION BY user_id ORDER BY event_timestamp)
    WHEN 1 THEN 'media_play'
    WHEN 2 THEN 'recommendation_hit'
    -- 对应补充映射规则
  END AS next_event_type
FROM event_mapped

低版本Druid替代方案（若窗口函数不可用） #

如果你的Druid版本低于0.20.0（该版本正式完善窗口函数支持），可以通过自关联模拟LEAD逻辑：

SELECT
  t1.user_id,
  t1.event_timestamp,
  t1.event_type,
  t2.event_type AS next_event_type
FROM your_dataset t1
LEFT JOIN your_dataset t2
  ON t1.user_id = t2.user_id
  AND t2.event_timestamp > t1.event_timestamp
-- 只保留每个事件的下一个最早事件
QUALIFY ROW_NUMBER() OVER (PARTITION BY t1.user_id, t1.event_timestamp ORDER BY t2.event_timestamp) = 1

注意：自关联方式在数据量较大时性能较差，优先推荐升级Druid版本使用窗口函数。

内容的提问来源于stack exchange，提问作者JulietteN