This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 3e862a3 [FLINK-25436] Let Dispatcher only retain recovered jobs in
BlobServer
add de7cccc [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect
Flink with MySQL tables and ecosystem.
No new revisions were added by this update.
Summary of changes:
docs/content.zh/docs/connectors/table/jdbc.md | 126 ++++++--
docs/content.zh/docs/dev/table/catalogs.md | 2 +-
docs/content/docs/connectors/table/jdbc.md | 92 ++++--
docs/content/docs/dev/table/catalogs.md | 2 +-
.../jdbc/catalog/AbstractJdbcCatalog.java | 133 +++++++-
.../connector/jdbc/catalog/JdbcCatalogUtils.java | 3 +
.../flink/connector/jdbc/catalog/MySqlCatalog.java | 162 ++++++++++
.../connector/jdbc/catalog/PostgresCatalog.java | 338 ++++----------------
...lectFactory.java => JdbcDialectTypeMapper.java} | 25 +-
.../mysql/{MySQLDialect.java => MySqlDialect.java} | 6 +-
...ialectFactory.java => MySqlDialectFactory.java} | 6 +-
.../jdbc/dialect/mysql/MySqlTypeMapper.java | 223 +++++++++++++
.../jdbc/dialect/psql/PostgresTypeMapper.java | 174 +++++++++++
...flink.connector.jdbc.dialect.JdbcDialectFactory | 2 +-
.../flink/connector/jdbc/JdbcDataTypeTest.java | 2 +-
.../connector/jdbc/catalog/MySqlCatalogITCase.java | 346 +++++++++++++++++++++
.../jdbc/catalog/MySqlCatalogTestBase.java | 136 ++++++++
.../mysql-scripts/catalog-init-for-test.sql | 107 +++++++
18 files changed, 1527 insertions(+), 358 deletions(-)
create mode 100644
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/MySqlCatalog.java
copy
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/{mysql/MySQLDialectFactory.java
=> JdbcDialectTypeMapper.java} (60%)
rename
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/mysql/{MySQLDialect.java
=> MySqlDialect.java} (96%)
rename
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/mysql/{MySQLDialectFactory.java
=> MySqlDialectFactory.java} (89%)
create mode 100644
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/mysql/MySqlTypeMapper.java
create mode 100644
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/psql/PostgresTypeMapper.java
create mode 100644
flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/catalog/MySqlCatalogITCase.java
create mode 100644
flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/catalog/MySqlCatalogTestBase.java
create mode 100644
flink-connectors/flink-connector-jdbc/src/test/resources/mysql-scripts/catalog-init-for-test.sql
