我希望Flink程序中的所有操作符都能将记录插入到一个副流(除了主输出流(中。事实上,我正在寻找类似侧面输出的东西其中可以从所有类型的运算符(包括接收和源函数,而不仅仅是所有类型的进程函数(将记录插入到副流中你知道我该怎么做吗?
恐怕这是不可能的。只有流程函数可以具有通用的侧输出(窗口和CEP确实使用侧输出,但仅以非常特定的方式(。
你能激励我们为什么你想要源和汇的副产品吗?我可以看到这对处理异常有多有用。
我希望Flink程序中的所有操作符都能将记录插入到一个副流(除了主输出流(中。事实上,我正在寻找类似侧面输出的东西其中可以从所有类型的运算符(包括接收和源函数,而不仅仅是所有类型的进程函数(将记录插入到副流中你知道我该怎么做吗?
恐怕这是不可能的。只有流程函数可以具有通用的侧输出(窗口和CEP确实使用侧输出,但仅以非常特定的方式(。
你能激励我们为什么你想要源和汇的副产品吗?我可以看到这对处理异常有多有用。
javascript python java c# php android html jquery c++ css ios sql mysql arrays asp.net json python-3.x ruby-on-rails .net sql-server django objective-c excel regex ruby linux ajax iphone xml vba spring asp.net-mvc database wordpress string postgresql wpf windows xcode bash git oracle list vb.net multithreading eclipse algorithm macos powershell visual-studio image forms numpy scala function api selenium