streaminsight - StreamInsight 中的跳跃计数窗口

Question

我正在开发一个 StreamInsight 应用程序，它应该计算每N个输入的函数，即如果 N=10，那么我想计算：

x_1, x_2, ..., x_10  ---> output_1
x_11, x_12, ..., x_20 ---> output_2

等等

所以我想要的是一个Hopping Window，除了在 Count 而不是时间戳上参数化。

我不能使用计数窗口，因为每次计数改变时都会产生输出。

我正在寻找有关如何解决缺少"Hopping Count Window"的建议。

Answer 1

看看使用User-defined Stream Operator。事件将一一进入您的操作员，这将使维护最后 N 个事件/输入的集合变得容易。收到第 N 个事件后，进行计算，清除事件/输入集合，然后返回结果。