This is an automated email from the ASF dual-hosted git repository.
fanjia pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from 0369c7a883 [Fix][Transform] Support integer input for from_unixtime
function (#9738)
add b6c5d941b0 [Feature][MySQL CDC] MySQL cdc support start by time (#9735)
No new revisions were added by this update.
Summary of changes:
docs/en/connector-v2/source/MySQL-CDC.md | 3 +-
docs/zh/connector-v2/source/MySQL-CDC.md | 3 +-
.../connectors/cdc/base/config/StartupConfig.java | 2 +-
.../source/MySqlIncrementalSourceFactory.java | 4 +
.../cdc/mysql/source/MySqlSourceOptions.java | 5 +-
.../cdc/mysql/source/offset/BinlogOffset.java | 6 +
.../mysql/source/offset/BinlogOffsetFactory.java | 3 +-
.../reader/fetch/MySqlSourceFetchTaskContext.java | 23 +-
.../reader/fetch/binlog/MySqlBinlogFetchTask.java | 118 +++++++++-
.../cdc/mysql/utils/MySqlConnectionUtils.java | 93 ++++++++
.../mysql/MysqlCDCSpecificStartingOffsetIT.java | 246 +++++++++++++++++++++
..._offset.conf => mysqlcdc_timestamp_offset.conf} | 7 +-
12 files changed, 493 insertions(+), 20 deletions(-)
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-cdc-mysql-e2e/src/test/resources/{mysqlcdc_earliest_offset.conf
=> mysqlcdc_timestamp_offset.conf} (90%)
