Hi Wei,
what do you mean be "windowedStream"?
The result of
dataStream.join(otherStream).where().equalTo()
expects a window to be specified. In each window, based on the time and window
characteristics you defined, both sources will collect elements that fit into
the window and, at its end,
Hello Flink,
one question about join operator:
Flink Docu said "Join two data streams on a given key and a common
window",= does "common window" mean that the joined stream is
windowedStream?
If it is normal datastream (not windowed), could the stream be windowed
aga= in with different