This is an automated email from the ASF dual-hosted git repository.
snuyanzin pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-jdbc.git
from 7025642d [hotfix] Update flink-connector-parent to 1.1.0, add support
Flink 1.20-SNAPSHOT
add ab5d6159 [FLINK-33459][Connector/JDBC] Support the new source that
keeps the same functionality as the original JDBC input format
No new revisions were added by this update.
Summary of changes:
flink-connector-jdbc/pom.xml | 27 +-
.../flink/connector/jdbc/JdbcInputFormat.java | 4 +
.../connections/SimpleJdbcConnectionProvider.java | 6 +-
.../flink/connector/jdbc/source/JdbcSource.java | 198 ++++++++++++++
.../connector/jdbc/source/JdbcSourceBuilder.java | 254 ++++++++++++++++++
.../connector/jdbc/source/JdbcSourceOptions.java | 52 ++++
.../enumerator/JdbcSourceEnumStateSerializer.java | 124 +++++++++
.../source/enumerator/JdbcSourceEnumerator.java | 140 ++++++++++
.../enumerator/JdbcSourceEnumeratorState.java | 94 +++++++
.../enumerator/JdbcSqlSplitEnumeratorBase.java | 100 +++++++
.../enumerator/SqlTemplateSplitEnumerator.java | 124 +++++++++
.../jdbc/source/reader/JdbcRecordEmitter.java | 45 ++++
.../jdbc/source/reader/JdbcSourceReader.java | 71 +++++
.../jdbc/source/reader/JdbcSourceSplitReader.java | 289 +++++++++++++++++++++
.../jdbc/source/reader/RecordAndOffset.java | 63 +++++
.../reader/extractor/ResultExtractor.java} | 35 +--
.../reader/extractor/RowResultExtractor.java} | 23 +-
.../jdbc/source/split/CheckpointedOffset.java | 81 ++++++
.../jdbc/source/split/JdbcSourceSplit.java | 130 +++++++++
.../source/split/JdbcSourceSplitSerializer.java | 113 ++++++++
.../jdbc/source/split/JdbcSourceSplitState.java | 107 ++++++++
.../split/JdbcGenericParameterValuesProvider.java | 4 +-
.../JdbcNumericBetweenParametersProvider.java | 17 +-
.../jdbc/split/JdbcParameterValuesProvider.java | 6 +-
.../reader/splitreader/TestingSplitsChange.java} | 17 +-
.../flink/connector/jdbc/JdbcDataTestBase.java | 12 +
.../jdbc/source/JdbcSourceBuilderTest.java | 145 +++++++++++
.../connector/jdbc/source/JdbcSourceITCase.java | 143 ++++++++++
.../JdbcSourceEnumStateSerializerTest.java | 96 +++++++
.../enumerator/JdbcSourceEnumeratorTest.java | 114 ++++++++
.../jdbc/source/reader/JdbcSourceReaderTest.java | 79 ++++++
.../source/reader/JdbcSourceSplitReaderTest.java | 144 ++++++++++
.../split/JdbcSourceSplitSerializerTest.java | 80 ++++++
33 files changed, 2896 insertions(+), 41 deletions(-)
create mode 100644
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/JdbcSource.java
create mode 100644
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/JdbcSourceBuilder.java
create mode 100644
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/JdbcSourceOptions.java
create mode 100644
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/enumerator/JdbcSourceEnumStateSerializer.java
create mode 100644
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/enumerator/JdbcSourceEnumerator.java
create mode 100644
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/enumerator/JdbcSourceEnumeratorState.java
create mode 100644
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/enumerator/JdbcSqlSplitEnumeratorBase.java
create mode 100644
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/enumerator/SqlTemplateSplitEnumerator.java
create mode 100644
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/reader/JdbcRecordEmitter.java
create mode 100644
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/reader/JdbcSourceReader.java
create mode 100644
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/reader/JdbcSourceSplitReader.java
create mode 100644
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/reader/RecordAndOffset.java
copy
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/{converter/JdbcRowConverter.java
=> source/reader/extractor/ResultExtractor.java} (53%)
copy
flink-connector-jdbc/src/{test/java/org/apache/flink/connector/jdbc/testutils/functions/JdbcResultSetBuilder.java
=>
main/java/org/apache/flink/connector/jdbc/source/reader/extractor/RowResultExtractor.java}
(55%)
create mode 100644
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/split/CheckpointedOffset.java
create mode 100644
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/split/JdbcSourceSplit.java
create mode 100644
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/split/JdbcSourceSplitSerializer.java
create mode 100644
flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/source/split/JdbcSourceSplitState.java
copy
flink-connector-jdbc/src/test/java/org/apache/flink/connector/{jdbc/testutils/functions/JdbcResultSetBuilder.java
=> base/source/reader/splitreader/TestingSplitsChange.java} (70%)
create mode 100644
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/source/JdbcSourceBuilderTest.java
create mode 100644
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/source/JdbcSourceITCase.java
create mode 100644
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/source/enumerator/JdbcSourceEnumStateSerializerTest.java
create mode 100644
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/source/enumerator/JdbcSourceEnumeratorTest.java
create mode 100644
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/source/reader/JdbcSourceReaderTest.java
create mode 100644
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/source/reader/JdbcSourceSplitReaderTest.java
create mode 100644
flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/source/split/JdbcSourceSplitSerializerTest.java
