Heres the proposal for supporting it in "append" mode - https://github.com/apache/spark/pull/23576. You could see if it addresses your requirement and post your feedback in the PR. For "update" mode its going to be much harder to support this without first adding support for "retractions", otherwise we would end up with wrong results.
- Arun On Mon, 20 May 2019 at 01:34, Gabor Somogyi <gabor.g.somo...@gmail.com> wrote: > There is PR for this but not yet merged. > > On Mon, May 20, 2019 at 10:13 AM 张万新 <kevinzwx1...@gmail.com> wrote: > >> Hi there, >> >> I'd like to know what's the root reason why multiple aggregations on >> streaming dataframe is not allowed since it's a very useful feature, and >> flink has supported it for a long time. >> >> Thanks. >> >
