Hey guys, We have been discussing the possible syntaxes for doing temporal operators on DataStreams(join, corss, cogroup etc) with Paris and we have come up with two alternatives.
1. ds1.join(ds2).onWindow(5, seconds).every(2, seconds).where(...).equalTo(...) 2. ds1.connect(ds2).onWindow(5, seconds).every(2, seconds).join().where(...).equalTo(...) Basically the difference is that in the second case we produce a binary stream of 2 types by the connect method and we create a window on that before join/cross. While in the first case the join/cross/etc is the method of the DataStream itself and we define the window after calling join/cross/etc We currently have the first one. Which one do you think is the more intuitive? (Or propose an alternative) Cheers, Gyula & Paris
