Nesper - MarketDepth.std.unique(key).win:time_batch(500毫秒与MarketDepth.win:time_batch(500毫秒).std:unique(密钥)之间的差异

Question

在Nesper中执行以下语句有什么区别

MarketDepth.std.unique(key).win:time_batch(500 msec) vs MarketDepth.win:time_batch(500 msec).std:unique(key)

第一个是不是每500毫秒批处理一次具有唯一密钥的所有事件？而第二个是批处理所有事件，并每500毫秒发送一次所有唯一密钥？

如果使用命令output every 500 msec而不是time_batch呢？任何帮助都将不胜感激。

Answer 1

这是没有区别的。更长的话说，按键唯一的最后一个事件和最后500毫秒的事件之间的交集与最后500毫秒的事件和按键唯一的最后一个事件之间的交集相同。

单独考虑，time_batch数据窗口和输出速率限制实现了类似的功能。例如，与特定的select子句和其他数据窗口一起使用时，它们不会。