This is an automated email from the ASF dual-hosted git repository.
sjwiesman pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from d18d1f4 [FLINK-24303][coordination] Failure when creating a source
enumerator lead to full failover, not JobManager failure.
add de92c9e [FLINK-24253][jdbc] Migrate JDBC validation from TableSchema
to DataType
add 223e961 [FLINK-24253][jdbc] Load Dialects via ServiceLoader
add 1bcb91e [FLINK-24253][jdbc] Mark Dialect as Public and move converter
out of internal package
add 67a59f4 [FLINK-24253][jdbc] Cleanup JavaDoc of newly public interfaces
add 412b49a [FLINK-24253][jdbc] move default implementations to
AbstractDialect
No new revisions were added by this update.
Summary of changes:
.../connector/jdbc/catalog/JdbcCatalogUtils.java | 6 +-
.../converter/AbstractJdbcRowConverter.java | 8 +-
.../{internal => }/converter/JdbcRowConverter.java | 4 +-
.../connector/jdbc/dialect/AbstractDialect.java | 242 ++++++++++++++++++---
.../flink/connector/jdbc/dialect/JdbcDialect.java | 171 ++++++---------
.../connector/jdbc/dialect/JdbcDialectFactory.java | 49 +++++
.../connector/jdbc/dialect/JdbcDialectLoader.java | 106 +++++++++
.../jdbc/dialect/{ => derby}/DerbyDialect.java | 65 +++---
.../DerbyDialectFactory.java} | 31 ++-
.../jdbc/dialect/{ => mysql}/MySQLDialect.java | 66 +++---
.../mysql/MySQLDialectFactory.java} | 26 +--
.../jdbc/dialect/{ => psql}/PostgresDialect.java | 65 +++---
.../psql/PostgresDialectFactory.java} | 26 +--
.../jdbc/internal/converter/DerbyRowConverter.java | 1 +
.../jdbc/internal/converter/MySQLRowConverter.java | 1 +
.../internal/converter/PostgresRowConverter.java | 1 +
.../TableInsertOrUpdateStatementExecutor.java | 2 +-
.../executor/TableSimpleStatementExecutor.java | 2 +-
.../internal/options/JdbcConnectorOptions.java | 18 +-
.../jdbc/internal/options/JdbcDmlOptions.java | 6 +-
.../statement/FieldNamedPreparedStatement.java | 3 +
.../jdbc/table/JdbcDynamicTableFactory.java | 9 +-
.../jdbc/table/JdbcOutputFormatBuilder.java | 2 +-
.../jdbc/table/JdbcRowDataInputFormat.java | 2 +-
.../jdbc/table/JdbcRowDataLookupFunction.java | 11 +-
.../jdbc/table/JdbcTableSourceSinkFactory.java | 4 +-
.../flink/table/descriptors/JdbcValidator.java | 16 +-
...flink.connector.jdbc.dialect.JdbcDialectFactory | 18 ++
.../converter/AbstractJdbcRowConverterTest.java | 2 +-
.../FieldNamedPreparedStatementImplTest.java | 6 +-
.../connector/jdbc/table/JdbcOutputFormatTest.java | 4 +-
31 files changed, 617 insertions(+), 356 deletions(-)
rename
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/{internal
=> }/converter/AbstractJdbcRowConverter.java (97%)
rename
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/{internal
=> }/converter/JdbcRowConverter.java (93%)
create mode 100644
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialectFactory.java
create mode 100644
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialectLoader.java
rename
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/{
=> derby}/DerbyDialect.java (65%)
rename
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/{JdbcDialects.java
=> derby/DerbyDialectFactory.java} (55%)
rename
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/{
=> mysql}/MySQLDialect.java (70%)
copy
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/{internal/converter/MySQLRowConverter.java
=> dialect/mysql/MySQLDialectFactory.java} (61%)
rename
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/{
=> psql}/PostgresDialect.java (73%)
copy
flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/{internal/converter/MySQLRowConverter.java
=> dialect/psql/PostgresDialectFactory.java} (61%)
create mode 100644
flink-connectors/flink-connector-jdbc/src/main/resources/META-INF/services/org.apache.flink.connector.jdbc.dialect.JdbcDialectFactory
rename
flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/{internal
=> }/converter/AbstractJdbcRowConverterTest.java (97%)
