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