Re: Appending Windowed Aggregates to Events

2017-06-26 Thread Ted Yu
In case no-sql store is considered, please take a look at base Cheers Original message From: "Jain, Ankit" Date: 6/26/17 12:41 PM (GMT-08:00) To: Tim Stearn , user@flink.apache.org Subject: Re: Appending Windowed Aggregates to Events You could load the historic

Re: Appending Windowed Aggregates to Events

2017-06-26 Thread Jain, Ankit
oracle. Thanks Ankit From: Tim Stearn Date: Friday, June 23, 2017 at 3:59 PM To: "user@flink.apache.org" Subject: Appending Windowed Aggregates to Events Hello All, I’m *very* new to Flink. I read through the documentation and played with some sample code, but I’m struggling to g

Re: Appending Windowed Aggregates to Events

2017-06-26 Thread Fabian Hueske
Hi Tim, your requirements seem to be similar to what you can do in SQL with an OVER window aggregation. OVER window aggregates are computed for each row and enrich the existing fields with aggregates. The aggregates are computed over a range of rows that precede (or follow) the current row. This m

Appending Windowed Aggregates to Events

2017-06-23 Thread Tim Stearn
Hello All, I'm *very* new to Flink. I read through the documentation and played with some sample code, but I'm struggling to get started with my requirements. We want to use Flink to maintain windowed aggregates as part of a transaction monitoring application. These would use sliding window