flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From GustavoVM <momente.gust...@gmail.com>
Subject Custom state serializer in the Scala DataStream API
Date Tue, 13 Nov 2018 17:09:21 GMT
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/

Mime
View raw message