Flink?中所有操作员的侧面输出



我希望Flink程序中的所有操作符都能将记录插入到一个副流(除了主输出流(中。事实上,我正在寻找类似侧面输出的东西其中可以从所有类型的运算符(包括接收和源函数,而不仅仅是所有类型的进程函数(将记录插入到副流中你知道我该怎么做吗?

恐怕这是不可能的。只有流程函数可以具有通用的侧输出(窗口和CEP确实使用侧输出,但仅以非常特定的方式(。

你能激励我们为什么你想要源和汇的副产品吗?我可以看到这对处理异常有多有用。

相关内容

  • 没有找到相关文章

最新更新