Hi,
ListCheckpointed is just a simplified/shortcut version of the more powerful
interface CheckpointedFunction. If Serializable does not cover your use case, I
suggest you to go with CheckpointedFunction and create your states in
initialize(…) via the
initializationContext.getOperatorStateStor
Hi,
ListCheckpointed only accept Serializable object at the moment, which make it
cumbersome to checkpoint avro objects (have to convert them to byte arrays
first). Is there any plan to support avro object directly?
Best regards,
Kien
