You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ja...@apache.org on 2020/05/13 12:56:17 UTC
[flink] branch master updated (09495d1 -> 6a6a439)
This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 09495d1 [FLINK-17648][yarn] Make YarnApplicationClusterEntryPoint use the yarn.application-master.port
add 6a6a439 [FLINK-17537][jdbc] Refactor flink-jdbc connector structure
No new revisions were added by this update.
Summary of changes:
docs/dev/batch/index.md | 4 +-
docs/dev/batch/index.zh.md | 4 +-
docs/dev/connectors/jdbc.md | 6 +-
docs/dev/connectors/jdbc.zh.md | 6 +-
docs/dev/table/catalogs.md | 18 +-
docs/dev/table/catalogs.zh.md | 18 +-
docs/dev/table/connect.md | 62 +----
docs/dev/table/connect.zh.md | 62 +----
.../{flink-jdbc => flink-connector-jdbc}/pom.xml | 4 +-
.../flink/api/java/io/jdbc/JDBCInputFormat.java | 211 ++++++++++++++
.../flink/api/java/io/jdbc/JDBCOutputFormat.java | 22 +-
.../jdbc/split/GenericParameterValuesProvider.java | 16 +-
.../split/NumericBetweenParametersProvider.java | 65 +++++
.../io/jdbc/split/ParameterValuesProvider.java | 10 +-
.../connector}/jdbc/JdbcConnectionOptions.java | 4 +-
.../connector}/jdbc/JdbcExecutionOptions.java | 18 +-
.../flink/connector/jdbc/JdbcInputFormat.java} | 113 ++++----
.../flink/connector/jdbc/JdbcOutputFormat.java | 143 ++++++++++
.../org/apache/flink/connector}/jdbc/JdbcSink.java | 7 +-
.../connector}/jdbc/JdbcStatementBuilder.java | 4 +-
.../jdbc/catalog/AbstractJdbcCatalog.java} | 14 +-
.../flink/connector/jdbc/catalog/JdbcCatalog.java} | 14 +-
.../connector/jdbc/catalog/JdbcCatalogUtils.java} | 18 +-
.../connector}/jdbc/catalog/PostgresCatalog.java | 14 +-
.../connector}/jdbc/catalog/PostgresTablePath.java | 2 +-
.../jdbc/catalog/factory/JdbcCatalogFactory.java} | 24 +-
.../flink/connector/jdbc/dialect/JdbcDialect.java} | 12 +-
.../connector/jdbc/dialect/JdbcDialects.java} | 28 +-
.../jdbc/internal}/AbstractJdbcOutputFormat.java | 12 +-
.../jdbc/internal}/GenericJdbcSinkFunction.java | 11 +-
.../jdbc/internal}/JdbcBatchingOutputFormat.java | 63 +++--
.../internal}/TableJdbcUpsertOutputFormat.java | 13 +-
.../connection}/JdbcConnectionProvider.java | 2 +-
.../connection}/SimpleJdbcConnectionProvider.java | 6 +-
.../converter/AbstractJdbcRowConverter.java} | 12 +-
.../internal}/converter/DerbyRowConverter.java | 4 +-
.../jdbc/internal/converter/JdbcRowConverter.java} | 6 +-
.../internal}/converter/MySQLRowConverter.java | 4 +-
.../internal}/converter/PostgresRowConverter.java | 8 +-
.../executor/InsertOrUpdateJdbcExecutor.java | 4 +-
.../executor/JdbcBatchStatementExecutor.java | 4 +-
.../executor/KeyedBatchStatementExecutor.java | 4 +-
.../executor/SimpleBatchStatementExecutor.java | 4 +-
.../jdbc/internal/options}/JdbcDmlOptions.java | 16 +-
.../jdbc/internal/options}/JdbcInsertOptions.java | 4 +-
.../jdbc/internal/options/JdbcLookupOptions.java} | 26 +-
.../jdbc/internal/options/JdbcOptions.java} | 47 ++--
.../jdbc/internal/options/JdbcReadOptions.java} | 26 +-
.../internal/options}/JdbcTypedQueryOptions.java | 9 +-
.../split/JdbcGenericParameterValuesProvider.java} | 12 +-
.../JdbcNumericBetweenParametersProvider.java} | 18 +-
.../jdbc/split/JdbcParameterValuesProvider.java} | 12 +-
.../connector/jdbc/table/JdbcLookupFunction.java} | 44 +--
.../connector/jdbc/table/JdbcTableSource.java} | 78 +++---
.../jdbc/table/JdbcTableSourceSinkFactory.java} | 75 ++---
.../connector/jdbc/table/JdbcUpsertTableSink.java} | 50 ++--
.../flink/connector/jdbc/utils}/JdbcTypeUtil.java | 17 +-
.../flink/connector/jdbc/utils/JdbcUtils.java} | 6 +-
.../table/descriptors/JdbcCatalogDescriptor.java} | 14 +-
.../table/descriptors/JdbcCatalogValidator.java} | 6 +-
.../flink/table/descriptors/JdbcValidator.java} | 8 +-
.../org.apache.flink.table.factories.TableFactory | 4 +-
.../api/java/io/jdbc/JDBCInputFormatTest.java | 110 ++++----
.../api/java/io/jdbc/JDBCOutputFormatTest.java | 74 +++--
.../apache/flink/connector}/jdbc/DbMetadata.java | 2 +-
.../flink/connector}/jdbc/DerbyDbMetadata.java | 2 +-
.../flink/connector/jdbc/JdbcDataTestBase.java} | 33 ++-
.../flink/connector/jdbc/JdbcDataTypeTest.java} | 4 +-
.../apache/flink/connector}/jdbc/JdbcITCase.java | 20 +-
.../flink/connector/jdbc/JdbcInputFormatTest.java} | 259 +++++++++---------
.../flink/connector/jdbc/JdbcOutputFormatTest.java | 304 +++++++++++++++++++++
.../apache/flink/connector/jdbc/JdbcTestBase.java} | 14 +-
.../flink/connector}/jdbc/JdbcTestFixture.java | 30 +-
.../jdbc/catalog/JdbcCatalogUtilsTest.java} | 16 +-
.../jdbc/catalog/PostgresCatalogITCase.java | 4 +-
.../jdbc/catalog/PostgresCatalogTest.java | 13 +-
.../jdbc/catalog/PostgresCatalogTestBase.java | 10 +-
.../jdbc/catalog/PostgresTablePathTest.java | 2 +-
.../catalog/factory/JdbcCatalogFactoryTest.java} | 24 +-
.../connector/jdbc/internal/JdbcFullTest.java | 180 ++++++++++++
.../jdbc/internal}/JdbcTableOutputFormatTest.java | 26 +-
.../NumericBetweenParametersProviderTest.java | 16 +-
.../jdbc/table/JdbcAppendOnlyWriterTest.java} | 22 +-
.../jdbc/table/JdbcLookupFunctionITCase.java} | 22 +-
.../jdbc/table/JdbcTableSourceITCase.java} | 13 +-
.../table/JdbcTableSourceSinkFactoryTest.java} | 45 +--
.../jdbc/table/JdbcUpsertTableSinkITCase.java} | 14 +-
.../connector/jdbc/utils}/JdbcTypeUtilTest.java | 4 +-
.../descriptors/JdbcCatalogDescriptorTest.java} | 10 +-
.../src/test/resources/log4j2-test.properties | 0
.../api/java/io/jdbc/JDBCAppendTableSink.java | 126 ---------
.../java/io/jdbc/JDBCAppendTableSinkBuilder.java | 140 ----------
.../flink/api/java/io/jdbc/JdbcSinkFunction.java | 67 -----
.../api/java/io/jdbc/JDBCAppendTableSinkTest.java | 95 -------
.../flink/api/java/io/jdbc/JDBCFullTest.java | 140 ----------
flink-connectors/pom.xml | 2 +-
tools/ci/stage.sh | 2 +-
97 files changed, 1863 insertions(+), 1534 deletions(-)
rename flink-connectors/{flink-jdbc => flink-connector-jdbc}/pom.xml (97%)
create mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java
rename flink-connectors/{flink-jdbc => flink-connector-jdbc}/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCOutputFormat.java (87%)
copy flink-connectors/{flink-jdbc => flink-connector-jdbc}/src/main/java/org/apache/flink/api/java/io/jdbc/split/GenericParameterValuesProvider.java (75%)
create mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/split/NumericBetweenParametersProvider.java
copy flink-connectors/{flink-jdbc => flink-connector-jdbc}/src/main/java/org/apache/flink/api/java/io/jdbc/split/ParameterValuesProvider.java (83%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io => flink-connector-jdbc/src/main/java/org/apache/flink/connector}/jdbc/JdbcConnectionOptions.java (94%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io => flink-connector-jdbc/src/main/java/org/apache/flink/connector}/jdbc/JdbcExecutionOptions.java (81%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcInputFormat.java} (81%)
create mode 100644 flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcOutputFormat.java
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io => flink-connector-jdbc/src/main/java/org/apache/flink/connector}/jdbc/JdbcSink.java (88%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io => flink-connector-jdbc/src/main/java/org/apache/flink/connector}/jdbc/JdbcStatementBuilder.java (91%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/catalog/AbstractJDBCCatalog.java => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/AbstractJdbcCatalog.java} (96%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/catalog/JDBCCatalog.java => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/JdbcCatalog.java} (87%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/catalog/JDBCCatalogUtils.java => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/JdbcCatalogUtils.java} (76%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io => flink-connector-jdbc/src/main/java/org/apache/flink/connector}/jdbc/catalog/PostgresCatalog.java (96%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io => flink-connector-jdbc/src/main/java/org/apache/flink/connector}/jdbc/catalog/PostgresTablePath.java (98%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/catalog/factory/JDBCCatalogFactory.java => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/factory/JdbcCatalogFactory.java} (79%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/dialect/JDBCDialect.java => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialect.java} (93%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/dialect/JDBCDialects.java => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialects.java} (93%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal}/AbstractJdbcOutputFormat.java (85%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal}/GenericJdbcSinkFunction.java (86%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal}/JdbcBatchingOutputFormat.java (80%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal}/TableJdbcUpsertOutputFormat.java (89%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/connection}/JdbcConnectionProvider.java (94%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/connection}/SimpleJdbcConnectionProvider.java (89%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/source/row/converter/AbstractJDBCRowConverter.java => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/converter/AbstractJdbcRowConverter.java} (85%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/source/row => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal}/converter/DerbyRowConverter.java (88%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/source/row/converter/JDBCRowConverter.java => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/converter/JdbcRowConverter.java} (88%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/source/row => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal}/converter/MySQLRowConverter.java (88%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/source/row => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal}/converter/PostgresRowConverter.java (89%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal}/executor/InsertOrUpdateJdbcExecutor.java (97%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal}/executor/JdbcBatchStatementExecutor.java (94%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal}/executor/KeyedBatchStatementExecutor.java (95%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal}/executor/SimpleBatchStatementExecutor.java (94%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options}/JdbcDmlOptions.java (88%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options}/JdbcInsertOptions.java (93%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCLookupOptions.java => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcLookupOptions.java} (77%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCOptions.java => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcOptions.java} (74%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCReadOptions.java => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcReadOptions.java} (87%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options}/JdbcTypedQueryOptions.java (83%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/split/GenericParameterValuesProvider.java => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/split/JdbcGenericParameterValuesProvider.java} (74%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/split/NumericBetweenParametersProvider.java => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/split/JdbcNumericBetweenParametersProvider.java} (84%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/split/ParameterValuesProvider.java => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/split/JdbcParameterValuesProvider.java} (77%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCLookupFunction.java => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcLookupFunction.java} (86%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCTableSource.java => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcTableSource.java} (75%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCTableSourceSinkFactory.java => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcTableSourceSinkFactory.java} (76%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCUpsertTableSink.java => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcUpsertTableSink.java} (80%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/utils}/JdbcTypeUtil.java (92%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCUtils.java => flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/utils/JdbcUtils.java} (98%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/table/descriptors/JDBCCatalogDescriptor.java => flink-connector-jdbc/src/main/java/org/apache/flink/table/descriptors/JdbcCatalogDescriptor.java} (82%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/table/descriptors/JDBCCatalogValidator.java => flink-connector-jdbc/src/main/java/org/apache/flink/table/descriptors/JdbcCatalogValidator.java} (90%)
rename flink-connectors/{flink-jdbc/src/main/java/org/apache/flink/table/descriptors/JDBCValidator.java => flink-connector-jdbc/src/main/java/org/apache/flink/table/descriptors/JdbcValidator.java} (95%)
rename flink-connectors/{flink-jdbc => flink-connector-jdbc}/src/main/resources/META-INF/services/org.apache.flink.table.factories.TableFactory (85%)
copy flink-connectors/{flink-jdbc => flink-connector-jdbc}/src/test/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormatTest.java (73%)
rename flink-connectors/{flink-jdbc => flink-connector-jdbc}/src/test/java/org/apache/flink/api/java/io/jdbc/JDBCOutputFormatTest.java (73%)
rename flink-connectors/{flink-jdbc/src/test/java/org/apache/flink/api/java/io => flink-connector-jdbc/src/test/java/org/apache/flink/connector}/jdbc/DbMetadata.java (96%)
rename flink-connectors/{flink-jdbc/src/test/java/org/apache/flink/api/java/io => flink-connector-jdbc/src/test/java/org/apache/flink/connector}/jdbc/DerbyDbMetadata.java (97%)
rename flink-connectors/{flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/JDBCDataTestBase.java => flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/JdbcDataTestBase.java} (51%)
rename flink-connectors/{flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/JDBCDataTypeTest.java => flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/JdbcDataTypeTest.java} (98%)
rename flink-connectors/{flink-jdbc/src/test/java/org/apache/flink/api/java/io => flink-connector-jdbc/src/test/java/org/apache/flink/connector}/jdbc/JdbcITCase.java (82%)
rename flink-connectors/{flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormatTest.java => flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/JdbcInputFormatTest.java} (51%)
create mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/JdbcOutputFormatTest.java
rename flink-connectors/{flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/JDBCTestBase.java => flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/JdbcTestBase.java} (72%)
rename flink-connectors/{flink-jdbc/src/test/java/org/apache/flink/api/java/io => flink-connector-jdbc/src/test/java/org/apache/flink/connector}/jdbc/JdbcTestFixture.java (85%)
rename flink-connectors/{flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/catalog/JDBCCatalogUtilsTest.java => flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/catalog/JdbcCatalogUtilsTest.java} (73%)
rename flink-connectors/{flink-jdbc/src/test/java/org/apache/flink/api/java/io => flink-connector-jdbc/src/test/java/org/apache/flink/connector}/jdbc/catalog/PostgresCatalogITCase.java (97%)
rename flink-connectors/{flink-jdbc/src/test/java/org/apache/flink/api/java/io => flink-connector-jdbc/src/test/java/org/apache/flink/connector}/jdbc/catalog/PostgresCatalogTest.java (89%)
rename flink-connectors/{flink-jdbc/src/test/java/org/apache/flink/api/java/io => flink-connector-jdbc/src/test/java/org/apache/flink/connector}/jdbc/catalog/PostgresCatalogTestBase.java (95%)
rename flink-connectors/{flink-jdbc/src/test/java/org/apache/flink/api/java/io => flink-connector-jdbc/src/test/java/org/apache/flink/connector}/jdbc/catalog/PostgresTablePathTest.java (95%)
rename flink-connectors/{flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/catalog/factory/JDBCCatalogFactoryTest.java => flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/catalog/factory/JdbcCatalogFactoryTest.java} (81%)
create mode 100644 flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/internal/JdbcFullTest.java
rename flink-connectors/{flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc => flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/internal}/JdbcTableOutputFormatTest.java (80%)
rename flink-connectors/{flink-jdbc/src/test/java/org/apache/flink/api/java/io => flink-connector-jdbc/src/test/java/org/apache/flink/connector}/jdbc/split/NumericBetweenParametersProviderTest.java (77%)
rename flink-connectors/{flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/JDBCAppenOnlyWriterTest.java => flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcAppendOnlyWriterTest.java} (79%)
rename flink-connectors/{flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/JDBCLookupFunctionITCase.java => flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcLookupFunctionITCase.java} (88%)
rename flink-connectors/{flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/JDBCTableSourceITCase.java => flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcTableSourceITCase.java} (93%)
rename flink-connectors/{flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/JDBCTableSourceSinkFactoryTest.java => flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcTableSourceSinkFactoryTest.java} (87%)
rename flink-connectors/{flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/JDBCUpsertTableSinkITCase.java => flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/JdbcUpsertTableSinkITCase.java} (95%)
rename flink-connectors/{flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc => flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/utils}/JdbcTypeUtilTest.java (92%)
rename flink-connectors/{flink-jdbc/src/test/java/org/apache/flink/table/descriptors/JDBCCatalogDescriptorTest.java => flink-connector-jdbc/src/test/java/org/apache/flink/table/descriptors/JdbcCatalogDescriptorTest.java} (87%)
rename flink-connectors/{flink-jdbc => flink-connector-jdbc}/src/test/resources/log4j2-test.properties (100%)
delete mode 100644 flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCAppendTableSink.java
delete mode 100644 flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCAppendTableSinkBuilder.java
delete mode 100644 flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JdbcSinkFunction.java
delete mode 100644 flink-connectors/flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/JDBCAppendTableSinkTest.java
delete mode 100644 flink-connectors/flink-jdbc/src/test/java/org/apache/flink/api/java/io/jdbc/JDBCFullTest.java