I think this is that thread :) But as I said it is just a matter of what we want to add, and we can already do it.
On Wed, May 13, 2015 at 11:37 AM, Stephan Ewen <se...@apache.org> wrote: > This is a pretty central question, actually (timestamping the results of > windows). Let us kick off a separate thread for this... > > On Wed, May 13, 2015 at 9:20 AM, Bruno Cadonna < > cado...@informatik.hu-berlin.de> wrote: > > > -----BEGIN PGP SIGNED MESSAGE----- > > Hash: SHA1 > > > > Hi, > > > > I think timestamping results of a time window operator is essential. > > Without timestamps in the results, it is not possible to execute two > > time window operators one after the other. > > > > Cheers, > > Bruno > > > > On 12.05.2015 18:30, Aljoscha Krettek wrote: > > > Hi, I'll try to make it quick this time. I think we need to make > > > information about the event time of an element and information > > > about windows in which it resides accessible to the user. A simple > > > example would be the aggregation of some user behaviour, for > > > example: > > > > > > in = clickSource() > > > > > > analysedData = in .window(10 minutes).every(5 minutes) > > > .groupBy("userId") .filter(is something interesting) > > > .sum("something") > > > > > > analysedData.storeToMySystem() > > > > > > Now the results of this window aggregation tell me that at some > > > point, there was some window and in this window some attribute > > > summed up to this. This might not be very helpful. What might be > > > helpful is the information that there occurred a spike in something > > > at 12:45 on Wednesday. Therefore, I think we need to make this > > > information available somehow. > > > > > > I only have some rough Ideas about how this might work, but I > > > would first like to discuss whether others even think this > > > necessary. So fire away... > > > > > > Cheers, Aljoscha > > > > > > > - -- > > ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ > > > > Dr. Bruno Cadonna > > Postdoctoral Researcher > > > > Databases and Information Systems > > Department of Computer Science > > Humboldt-Universität zu Berlin > > > > http://www.informatik.hu-berlin.de/~cadonnab > > > > ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ > > -----BEGIN PGP SIGNATURE----- > > Version: GnuPG v1.4.11 (GNU/Linux) > > > > iQEcBAEBAgAGBQJVUvstAAoJEKdCIJx7flKwHBcIAIeyrcNuGUVqGYHuQmoEPj2r > > nFqSW6DZVwoLmqip300kfOdCWiwcnN881xOi9M0+JEaXPo0RyEfCvhsVJuJU3TS7 > > /9WYSWtlk81UOkkBtJef4YnQUpB4fwIQGymgwx7fHNGCaTdd5qQ9YqAuGrhpPol0 > > ZEcuZgQJSFGoz9k0kSkzit/2Td6xdkXesKq73ZZDNqVJvyUBu1oZyBs6DE2MHYo/ > > waWM5iI1G/mKvZR9WaoYcTLi0I2D0zIcEp62zRial18I1D+GCcxYVjqB2dS1eS12 > > eXMGBcvA+/WFW3oz2Na5f44Us7pb/RA65UminiacoOnVE7n9eLwy3miFUyb+ssE= > > =o4iT > > -----END PGP SIGNATURE----- > > >