Hi Gregory,
IMO, that would be a viable approach.
You have to ensure that all operators (except the sources) have the same
UIDs and state types but I guess you don't want to change the application
logic and just replace the sources.
What might be tricky is to perform the savepoint at the right
Hi group, I want to bootstrap some aggregates based on historic data in S3 and
then keep them updated based on a stream. To do this I was thinking of doing
something like processing all of the historic data, doing a save point, then
restoring my program from that save point but with a stream
