You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "davidchaava (via GitHub)" <gi...@apache.org> on 2026/07/28 13:03:24 UTC

[PR] [FLINK-39904][python] Add PyFlink GEOGRAPHY support [flink]

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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] [FLINK-39904][python] Add PyFlink GEOGRAPHY support [flink]

Posted by "davidchaava (via GitHub)" <gi...@apache.org>.
davidchaava commented on PR #28833:
URL: https://github.com/apache/flink/pull/28833#issuecomment-5107132257

   @flinkbot run azure


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] [FLINK-39904][python] Add PyFlink GEOGRAPHY support [flink]

Posted by "flinkbot (via GitHub)" <gi...@apache.org>.
flinkbot commented on PR #28833:
URL: https://github.com/apache/flink/pull/28833#issuecomment-5104614667

   <!--
   Meta data
   {
     "version" : 1,
     "metaDataEntries" : [ {
       "hash" : "671fc3c8b1395e071ecf51705a099469e05effe9",
       "status" : "UNKNOWN",
       "url" : "TBD",
       "triggerID" : "671fc3c8b1395e071ecf51705a099469e05effe9",
       "triggerType" : "PUSH"
     } ]
   }-->
   ## CI report:
   
   * 671fc3c8b1395e071ecf51705a099469e05effe9 UNKNOWN
   
   <details>
   <summary>Bot commands</summary>
     The @flinkbot bot supports the following commands:
   
    - `@flinkbot run azure` re-run the last Azure build
   </details>


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] [FLINK-39904][python] Add PyFlink GEOGRAPHY support [flink]

Posted by "davidchaava (via GitHub)" <gi...@apache.org>.
davidchaava commented on PR #28833:
URL: https://github.com/apache/flink/pull/28833#issuecomment-5118072232

   @flinkbot run azure


-- 
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: issues-unsubscribe@flink.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org