Hi, I am using the KeyedOneInputStreamOperatorTestHarness. With that, I can take a snapshot and then use OperatorSnapshotUtil to write and read it. I am wondering if I can take a savepoint using the test harness or write the snapshot as a savepoint in order to use the ExistingSavepoint API to examine the state. In particular, I would like to use readKeyedState on that class. Alternately, is there an example where a snapshot (instance of OperatorSubtaskState) is processed like ExistingSavepoint.readKeyedState processes a savepoint.
Thank you for your help. Best, Mike
