Please look into arbitrary stateful aggregation. I do not completely understand your problem though. If you could give me an example. I'd be happy to help
On Mon, 22 Apr 2019, 15:31 shicheng31...@gmail.com, <shicheng31...@gmail.com> wrote: > Hi ,all: > As we all known, structured streaming is used to handle incremental > problems. However, if I need to make an increment based on an initial > value, I need to get a previous state value when the program is > initialized. > Is there any way to assign an initial value to the 'state' ? Or > other solutions? > Thanks! > > ------------------------------ > shicheng31...@gmail.com >
