Bowen Li created FLINK-16811:
--------------------------------

             Summary: introduce JDBCRowConverter
                 Key: FLINK-16811
                 URL: https://issues.apache.org/jira/browse/FLINK-16811
             Project: Flink
          Issue Type: Improvement
          Components: Connectors / JDBC
            Reporter: Bowen Li
            Assignee: Bowen Li
             Fix For: 1.11.0


currently when JDBCInputFormat converts a JDBC result set row to Flink Row, it 
doesn't check the type returned from jdbc result set. Problem is that object 
from jdbc result set doesn't always match the corresponding type in relational 
db. E.g. a short column in Postgres actually returns a Integer via jdbc. And 
such mismatch can be db-dependent.

 

Thus, we introduce JDBCRowConverter interface to convert a db specific row from 
jdbc to Flink row. Dbs should implement their own row converters.

 

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to