You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by GustavoVM <mo...@gmail.com> on 2018/11/13 17:09:21 UTC

Custom state serializer in the Scala DataStream API

I need to have states that support schema migration. For that I intend to
serialize them using protobuf. For that I’ve create a custom TypeSerializer.

Unfortunately, I couldn’t find how to set the serializer used when I use
mapWithState in a KeyedStream. So any one could point me in the right
direction?



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/