jiayuasu opened a new issue, #3058: URL: https://github.com/apache/sedona/issues/3058
Part of #3054. ## Scope Add a Flink `TypeSerializer` for the `Geography` type so geography values can flow through the Flink Table/DataStream type system, mirroring the existing `GeometryTypeSerializer`. ## Tasks - [ ] Add `flink/src/main/java/org/apache/sedona/flink/GeographyTypeSerializer.java`, extending `TypeSerializer<org.apache.sedona.common.S2Geography.Geography>`. - [ ] Delegate serialization to `org.apache.sedona.common.S2Geography.GeographySerializer.serialize/deserialize` (length-prefixed, null-safe), matching the `GeometryTypeSerializer` layout. - [ ] Provide a `TypeSerializerSnapshot` for state compatibility, mirroring `GeometrySerializerSnapshot`. - [ ] Add a unit test covering a serialize/deserialize round-trip through the Flink `DataOutputView`/`DataInputView` API for point, polygon, and null geographies. ## Notes - `GeographySerializer.serialize` throws `IOException`, which is already compatible with the `TypeSerializer#serialize` override signature. - No `GeographyArrayTypeSerializer` in this issue — no geography function returns an array yet. This is the foundation for the constructor functions (next sub-issue) and Catalog registration. -- 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]
