Re: Is joined stream WindowedStream?

2017-07-27 Thread Nico Kruber
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,

Is joined stream WindowedStream?

2017-07-25 Thread xie wei
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