ApacheFlink-keyedstream的输出流在通过与广播流的 join后是keyedstream的输出流吗?


0

keyedstream的输出流在通过一个带有广播流的connect然后通过process函数之后仍然是keyed流吗?

1 答案


0

不,不是的。

key控流的 key不附加到流记录或流分区,而是在需要时使用计算 key的 key选择器函数。这就是为什么生成全新流记录的运算符(如窗口和进程函数)不会发出 key控流。一般来说, ProcessFunction的输出可能与输入不相似,因此原来的 key选择函数不再适用。


我来回答

写文章

提问题

面试题