You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@seatunnel.apache.org by ki...@apache.org on 2022/03/14 08:20:44 UTC

[incubator-seatunnel] branch dev updated (f2482c0 -> 23ed11f)

This is an automated email from the ASF dual-hosted git repository.

kirs pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git.


    from f2482c0  [Refactor][flink-connector][elastic] - Refactored code to extract constants from embedded literals (#1481)
     add 23ed11f  [fix] [flink-connector-jdbc] various jdbc type of dialect compatibility between JdbcSource and JdbcSink update first piece (#1472)

No new revisions were added by this update.

Summary of changes:
 pom.xml                                            |   8 +
 .../seatunnel-connector-flink-jdbc/pom.xml         |   5 +
 .../jdbc/input/DefaultTypeInformationMap.java      |  73 ++++++++
 .../flink/jdbc/input/JdbcInputFormat.java          | 198 +++++++++++++++++++++
 .../flink/jdbc/input/MysqlTypeInformationMap.java  |  75 ++++++++
 .../jdbc/input/PostgresTypeInformationMap.java     |  77 ++++++++
 .../flink/jdbc/input/TypeInformationMap.java       |  34 ++++
 .../apache/seatunnel/flink/source/JdbcSource.java  |  84 +++------
 8 files changed, 494 insertions(+), 60 deletions(-)
 create mode 100644 seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/jdbc/input/DefaultTypeInformationMap.java
 create mode 100644 seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/jdbc/input/JdbcInputFormat.java
 create mode 100644 seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/jdbc/input/MysqlTypeInformationMap.java
 create mode 100644 seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/jdbc/input/PostgresTypeInformationMap.java
 create mode 100644 seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/jdbc/input/TypeInformationMap.java