Doing this generally is pretty hard. We will likely support algebraic aggregate eventually, but this is not currently slotted for 2.2. Instead I think we will add something like mapWithState that lets users compute arbitrary stateful things. What is your use case?
On Wed, Nov 16, 2016 at 6:58 PM, wszxyh <wsz...@163.com> wrote: > Hi > > Multiple streaming aggregations are not yet supported. When will it be > supported? Is it in the plan? > > Thanks > > > >
