Re: Structured Streaming initialized with cached data or others

2019-04-22 Thread Vipul Rajan
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
>


Structured Streaming initialized with cached data or others

2019-04-22 Thread shicheng31...@gmail.com
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