Jeremy Ber

05/25/2023, 9:29 PM
Hi there, trying to use the State Processor API with a toy problem-- I have a datastream app that will emit results if the keyed process function state is
, but i’ve purposely set it all to
. I run this app for some time to gather checkpoints, then i read that checkpoint into my StateProcessorAPI app. Within that app, I want to read the state and modify some elements to
, so when I restore the state, some keys will emit results. However, after modifying the state and reading this back in, there appears to be no elements in my written checkpoint. The examples of reading / modifying and writing state seem disconnected. Is there any end-to-end example of reading state, modifying, then writing it back out I can refer to? Or am I using this incorrectly?
👀 1