Gabor Somogyi created FLINK-38257:
-------------------------------------

             Summary: Add module dynamic function loading possibility
                 Key: FLINK-38257
                 URL: https://issues.apache.org/jira/browse/FLINK-38257
             Project: Flink
          Issue Type: New Feature
          Components: Table SQL / API
            Reporter: Gabor Somogyi


Modules like the state processor API could add SQL functions which are coming 
from external connector like Kafka, Iceberg, etc... It would be good to add a 
generic way to add a convenient way to have extra functions in a user friendly 
way:
 * Add Kafka connector jar to the classpath
 * 
LOAD MODULE state
 * 
SELECT * FROM get_kafka_offsets(...)

 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to