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.getOperatorStateStore().getListState(…). You can pass in type serializers (e.g. Avro) via the state descriptor. Hope this helps.
Best, Stefan > Am 21.07.2017 um 09:53 schrieb Kien Truong <duckientru...@gmail.com>: > > 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
