galenwarren opened a new pull request #152: URL: https://github.com/apache/flink-statefun/pull/152
This PR implements support for pluggable message payload serializers. It adds a new MessageFactoryType -- WITH_CUSTOM_PAYLOADS -- and a new class (MessageFactoryKey) that combines together MessageFactoryType and the name of a class to be used for payload serialization. This class must implement MessagePayloadSerializer. This is pretty straightforward change, mostly replacing uses of MessageFactoryType with MessageFactoryKey. The changes to the MessageTypeSerializer.Snapshot class are a bit interesting, in that the serialized format for the snapshot had to change, to include the name of the custom serializer class. The snapshot version number was bumped from 1 to 2, and the new version of the class can read snapshots of both version 1 and 2, which is confirmed via new unit tests in MessageTypeSerializerSnapshotTest. Any feedback or suggestions are welcome, and thanks to @igalshilman for pointing me in the right direction here. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
