假设我有一个包含股票价格的流。每条记录包括股票行情价格例如。阿普尔，102.23fb，23.34磅平均利润，101.99阿姆兹，45.43...我需要为aapl取最后60个价格记录。我不想使用时间窗口-只有最后60条记录。
70gysomp1#
您可以构建一个表来跟踪每台股票的最后60个价格，使用如下方法：
CREATE TABLE RECENT_PRICES AS SELECT tickerId, LATEST_BY_OFFSET(price, 60) AS PRICES FROM TICKS GROUP BY tickerId;
最新的按抵销单。这个 PRICES 列将是一个 ARRAY<DECIMAL(?, ?)> 持有最新的60个价格。注意：这是最新的偏移量，而不是时间戳。因此，无序的数据可能会导致问题。
PRICES
ARRAY<DECIMAL(?, ?)>
1条答案
按热度按时间70gysomp1#
您可以构建一个表来跟踪每台股票的最后60个价格，使用如下方法：
最新的按抵销单。
这个
PRICES列将是一个ARRAY<DECIMAL(?, ?)>持有最新的60个价格。注意：这是最新的偏移量，而不是时间戳。因此，无序的数据可能会导致问题。