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----- >