-
0 votesanswersviews
窗口操作员行为澄清后的Apache Flink KeyedStream
我要求澄清Apache Flink(1.6.0)在通过窗口发送事件后如何处理来自KeyedStreams的事件,并且已经应用了一些运算符(例如reduce()或process()) . 假设单个节点集群在执行了键控窗口流上的运算符之后,剩下的只有1个DataStream或者恰好是k个DataStream(其中k是键的唯一值的数量)? 为了澄清,考虑需要从某些来源读取事件,通过某些k键,将键控事件发...