This is an automated email from the ASF dual-hosted git repository.
shenghang pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from ec8919a877 [Bug][Connector-V2][File] Fix IndexOutOfBoundsException
when reading empty directories (#10373)
add 106c369db2 [Improve] cdc related options (#10372)
No new revisions were added by this update.
Summary of changes:
.../seatunnel/api/ConnectorOptionCheckTest.java | 20 ---
.../connectors/cdc/base/option/SourceOptions.java | 7 +
.../cdc/mongodb/MongodbIncrementalSource.java | 36 +++---
.../mongodb/MongodbIncrementalSourceFactory.java | 43 ++++---
...s.java => MongodbIncrementalSourceOptions.java} | 142 +--------------------
.../cdc/mongodb/config/MongodbSourceConfig.java | 4 -
.../config/MongodbSourceConfigProvider.java | 25 +---
...rceOptions.java => MongodbSourceConstants.java} | 137 +-------------------
.../MongoDBConnectorDeserializationSchema.java | 14 +-
.../cdc/mongodb/source/dialect/MongodbDialect.java | 2 +-
.../source/fetch/MongodbFetchTaskContext.java | 24 ++--
.../mongodb/source/fetch/MongodbScanFetchTask.java | 24 ++--
.../source/fetch/MongodbStreamFetchTask.java | 30 ++---
.../mongodb/source/offset/ChangeStreamOffset.java | 4 +-
.../splitters/SampleBucketSplitStrategy.java | 6 +-
.../source/splitters/ShardedSplitStrategy.java | 8 +-
.../source/splitters/SingleSplitStrategy.java | 2 +-
.../source/splitters/SplitVectorSplitStrategy.java | 4 +-
.../seatunnel/cdc/mongodb/utils/ChunkUtils.java | 2 +-
.../mongodb/utils/CollectionDiscoveryUtils.java | 2 +-
.../cdc/mongodb/utils/MongodbRecordUtils.java | 18 +--
.../seatunnel/cdc/mongodb/utils/MongodbUtils.java | 34 ++---
.../MongoDBConnectorDeserializationSchemaTest.java | 24 ++--
.../config/MySqlIncrementalSourceOptions.java | 64 ++++++++++
.../cdc/mysql/source/MySqlIncrementalSource.java | 5 +-
.../source/MySqlIncrementalSourceFactory.java | 53 ++++----
.../cdc/mysql/source/MySqlSourceOptions.java | 56 --------
.../OpengaussIncrementalSourceFactory.java | 13 +-
.../cdc/oracle/source/OracleIncrementalSource.java | 10 +-
.../source/OracleIncrementalSourceFactory.java | 59 +++++----
...ns.java => OracleIncrementalSourceOptions.java} | 3 +-
.../PostgresIncrementalSourceOptions.java} | 11 +-
.../config/PostgresSourceConfigFactory.java | 12 +-
.../source/PostgresIncrementalSourceFactory.java | 15 ++-
.../source/SqlServerIncrementalSource.java | 4 +-
.../source/SqlServerIncrementalSourceFactory.java | 47 +++----
...java => SqlServerIncrementalSourceOptions.java} | 3 +-
37 files changed, 350 insertions(+), 617 deletions(-)
copy
seatunnel-connectors-v2/connector-cdc/connector-cdc-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mongodb/config/{MongodbSourceOptions.java
=> MongodbIncrementalSourceOptions.java} (53%)
rename
seatunnel-connectors-v2/connector-cdc/connector-cdc-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mongodb/config/{MongodbSourceOptions.java
=> MongodbSourceConstants.java} (50%)
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/config/MySqlIncrementalSourceOptions.java
delete mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/source/MySqlSourceOptions.java
rename
seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/{OracleSourceOptions.java
=> OracleIncrementalSourceOptions.java} (95%)
rename
seatunnel-connectors-v2/connector-cdc/connector-cdc-postgres/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/postgres/{option/PostgresOptions.java
=> config/PostgresIncrementalSourceOptions.java} (84%)
rename
seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/source/{SqlServerSourceOptions.java
=> SqlServerIncrementalSourceOptions.java} (94%)
