The first one looks great and more compact. I think, the second one is less intuitive.
Cheers, Peter 2015-01-05 10:46 GMT+01:00 Gyula Fóra <gyf...@apache.org>: > 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 >
