[Flink-Question] In Flink parallel computing, how do different windows receive the data of their own partition, that is, how does Window determine which partition number the current Window belongs to?

[刘 文]

). Environment Flink1.7.2 WordCount local, stream processing
).source RecordWriter.emit(), for each element by key, divided into different 
partitions, the partition location of each element has been determined, the 
number of partitions is determined by DataStream.setParallelism(2)
 ). By copyFromSerializerToTargetChannel(int targetChannel) to write data to 
different channels, it is to send data to the window corresponding to different 
partitions (data is sent one by one)