Custom state serializer in the Scala DataStream API

[GustavoVM]

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/