Hi All,
I'm playing with the new mapWithState functionality but I can't get it
quite to work yet.
I'm doing two print() calls on the stream:
1. after mapWithState() call, first batch shows results - next batches
yield empty
2. after stateSnapshots(), always yields an empty RDD
Any pointers on
Just saw I'm not calling state.update() in my trackState function. I
guess that is the issue!
On Fri, Jan 29, 2016 at 9:36 AM, Sebastian Piu
wrote:
> Hi All,
>
> I'm playing with the new mapWithState functionality but I can't get it
> quite to work yet.
>
> I'm