radekaadek commented on PR #2452: URL: https://github.com/apache/sedona/pull/2452#issuecomment-3449719742
I guess the reason that it works now is because Flink automatically infers that a serializer that was passed in when that type was created. I suppose I would need to change all of the functions to use the custom serializer in order to get it to work with the module. Can you tell me how you were able to verify that the code actually uses custom serializers @jiayuasu ? I had been trying to put print statements inside of the geometry serialization class you mentioned but they never triggered when I was testing my code. I don't know if I'll be able to serialize the index as I don't see it called in a function anywhere but I'll try to instantiate it's type and serializer when the module is loaded. The types in the module resolve to this RAW type where a custom serializer can be specified and the types themselves should already be handled correctly by Flink. I'll write some tests and documentation for the module once I'll have some time on my hands. -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
