davidchaava opened a new pull request, #28833: URL: https://github.com/apache/flink/pull/28833
## What is the purpose of the change This PR adds PyFlink support for the GEOGRAPHY logical type. It exposes GEOGRAPHY in PyFlink table schemas, Python type conversion, Arrow conversion, Python function execution protocol, and SQL round-trip paths. This allows Python users to define GEOGRAPHY columns, pass GEOGRAPHY values through PyFlink APIs, and round-trip GEOGRAPHY values as WKB bytes where needed. This PR is stacked on the base GEOGRAPHY type support and SQL ST functions work. ## Brief change log - Add PyFlink `DataTypes.GEOGRAPHY()` support. - Add GEOGRAPHY handling in PyFlink table schema/type conversion. - Add GEOGRAPHY support to Python function execution coders and protocol. - Add GEOGRAPHY support in Java/Python bridge conversion utilities. - Add Arrow conversion support for GEOGRAPHY values. - Add PyFlink tests for schema, SQL, type conversion, and WKB round-trip behavior. ## Related changes This PR depends on the core GEOGRAPHY logical type support from [apache/flink#28740](https://github.com/apache/flink/pull/28740). It also depends on the SQL ST functions from [apache/flink#28788](https://github.com/apache/flink/pull/28788), which provide user-facing SQL constructors and accessors such as `ST_GEOGFROMTEXT`, `ST_GEOGFROMWKB`, `ST_ASTEXT`, and `ST_ASWKB`. ## Verifying this change This change is covered by PyFlink and Java/Python bridge tests. The added coverage includes: - PyFlink schema support for GEOGRAPHY. - PyFlink SQL usage with GEOGRAPHY constructors and accessors. - Python function execution protocol support for GEOGRAPHY. - WKB bytes round-trip behavior. - Arrow conversion support for GEOGRAPHY values. ## Does this pull request potentially affect one of the following parts - Dependencies: no - The public API: yes, PyFlink exposes GEOGRAPHY type support - The serializers: no - The runtime per-record code paths: yes, Python/Arrow conversion paths for GEOGRAPHY - Anything that affects deployment or recovery: no - The S3 file system connector: no ## Documentation This PR does not add end-user documentation. It extends PyFlink support for the GEOGRAPHY type introduced by the related GEOGRAPHY PRs. -- 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]
