在处理函数之后，带键的流是否变为不带键的？

Question

假设我在键控过程后得到一个流。

DataStream<T> stream= sourceStream.keyBy(key).window(window).apply(function);

生成的流是否仍被键入？我可以在该流中使用某些 Keyed 状态吗？

Answer 1

这是正确的，键控窗口或键控处理函数的输出不再是键控流。Flink 无法知道您执行的计算是否会保留之前的分区。

要使用键控状态，您需要重新对流进行键控，或者如果您确定原始键控已被保留，则可以使用reinterpretAsKeyedStream来通知 Flink 该流仍然是键控的。