使用處理時間測試觸發器

Question

我們可以測試具有取決於處理時間的觸發器的窗口的管道嗎？例如，具有全局窗口和在elementCountAtLeast 0上觸發的觸發器的流式管道將根據數據何時進入而具有不同的輸出，那麼我們可以以任何方式模擬這種情況嗎？

即使不是自動化測試，能夠嘗試不同的窗口戰略和看到他們的影響將是非常有用

Answer 1

完全同意。我們正在重寫DirectPipelineRunner以支持此操作。敬請關注！