使用处理时间测试触发器
Testing triggers with processing time
我们能否使用依赖于处理时间的触发器来测试具有 windows 的管道？例如，具有全局 window 和触发 elementCountAtLeast 0 的触发器的流式管道将根据数据何时进入而具有不同的输出，那么我们可以以任何方式模拟它吗？
即使不进行自动化测试，能够尝试不同的 windowing 策略并查看它们的影响也会非常有用
完全同意。我们正在重写 DirectPipelineRunner 以支持这一点。敬请期待！
我们能否使用依赖于处理时间的触发器来测试具有 windows 的管道？例如，具有全局 window 和触发 elementCountAtLeast 0 的触发器的流式管道将根据数据何时进入而具有不同的输出，那么我们可以以任何方式模拟它吗？
即使不进行自动化测试，能够尝试不同的 windowing 策略并查看它们的影响也会非常有用
完全同意。我们正在重写 DirectPipelineRunner 以支持这一点。敬请期待！