如何对存储在Hive中的数据进行滞后/超前操作？

Question

是否可以对存储在配置单元中的数据执行滞后、超前操作？

如有任何建议，我们将不胜感激！

Answer 1

现在，您需要使用SQLWindowing扩展来执行滞后、领先和其他窗口功能。

在未来，这将被转移到配置单元(请参阅HIVE-896)，语法将略有变化。

Answer 2

您可以使用LAG函数获取上一次的时间戳，示例如下：

NVL( LAG (currentTimestamp, 1) OVER (PARTITION BY [partinioned columns] ORDER BY currentTimestamp ASC)  , 0 ) AS previousTimestamp;

这里也是一样，缺省情况下，一行NVL( LEAD ( currentTimestamp，1) OVER (PARTITION by partinioned ORDER BY CurrentTimestamp ASC)，0) AS NextTimestamp；