Hive SQL 使用窗口函数判断最近 24 小时数据一致性

假设你有一个名为 'my_table' 的表，包含以下列：

• 'id'：唯一标识每个记录的 ID。
• 'value'：你想要比较的值。
• 'timestamp'：记录的时间戳。

以下是一个示例查询，用于确定最近 24 小时内 'value' 是否一致：

SELECT
  id,
  value,
  timestamp,
  CASE
    WHEN COUNT(DISTINCT value) OVER (ORDER BY timestamp RANGE BETWEEN INTERVAL '24' HOUR PRECEDING AND CURRENT ROW) = 1
    THEN 'yes'
    ELSE 'no'
  END AS is_consistent_within_24_hours
FROM
  my_table;

这个查询使用了 Hive 支持的窗口函数 COUNT(DISTINCT value) OVER (ORDER BY timestamp RANGE BETWEEN INTERVAL '24' HOUR PRECEDING AND CURRENT ROW)，它可以计算最近 24 小时内不同 'value' 的数量。如果这个数量为 1，说明最近 24 小时内所有记录的 'value' 都相同，结果为 'yes'；否则结果为 'no'。

注意，这个查询假设 'timestamp' 是按照时间顺序排列的。如果你的数据没有按照时间顺序排列，你需要先使用 ORDER BY timestamp 对数据进行排序。