davidchaava opened a new pull request, #16973: URL: https://github.com/apache/iceberg/pull/16973
Add support for mapping Flink GEOGRAPHY columns to native Iceberg geography types and reading them back through the Flink connector. This change: - maps Flink GEOGRAPHY to Iceberg GeographyType for Flink 1.20, 2.0, and 2.1; - maps Iceberg GeographyType back to Flink GEOGRAPHY when supported; - adds schema conversion coverage for top-level and nested GEOGRAPHY fields; - writes Iceberg GEOGRAPHY/GEOMETRY as Parquet BINARY with native Parquet logical annotations; - reads Parquet GEOGRAPHY values back into Flink GeographyData in the Flink 2.1 connector path; - suppresses unsafe lower/upper-bound metrics for spatial WKB values while preserving count metrics. Verified with compile and checkstyle for iceberg-parquet and iceberg-flink-2.1. -- 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] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
