This is an automated email from the ASF dual-hosted git repository.
gaojun2048 pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
from 91e632c52 [chore] fix pulsar consumer comment error (#3356)
add 2586f305b [feature][connector][cdc] CDC base classes (#3363)
No new revisions were added by this update.
Summary of changes:
LICENSE | 2 +
.../connector-cdc-base}/pom.xml | 51 ++++++---
.../cdc/base/config/BaseSourceConfig.java | 83 ++++++++++++++
.../connectors/cdc/base/config/SourceConfig.java} | 22 ++--
.../connectors/cdc/base/option/SourceOptions.java | 57 ++++++++++
.../connectors/cdc/base/option/StartupMode.java} | 34 +++---
.../connectors/cdc/base/option/StopMode.java | 23 ++--
.../cdc/base/source/IncrementalSource.java | 123 +++++++++++++++++++++
.../event/CompletedSnapshotSplitReportEvent.java | 8 +-
.../base/source/event/SnapshotSplitWatermark.java | 11 +-
.../connectors/cdc/base/source/offset/Offset.java | 99 +++++++++++++++++
.../cdc/base/source/offset/OffsetFactory.java} | 18 +--
.../source/split/CompletedSnapshotSplitInfo.java | 50 +++++++++
.../connectors/cdc/base/source/split/LogSplit.java | 70 ++++++++++++
.../cdc/base/source/split/SnapshotSplit.java} | 24 +++-
.../debezium/DebeziumDeserializationSchema.java | 29 ++---
.../connector-cdc}/pom.xml | 18 +--
seatunnel-connectors-v2/pom.xml | 1 +
18 files changed, 630 insertions(+), 93 deletions(-)
copy seatunnel-connectors-v2/{connector-file/connector-file-base-hadoop =>
connector-cdc/connector-cdc-base}/pom.xml (54%)
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/seatunnel/connectors/cdc/base/config/BaseSourceConfig.java
copy
seatunnel-connectors-v2/{connector-hudi/src/main/java/org/apache/seatunnel/connectors/seatunnel/hudi/source/HudiSourceState.java
=>
connector-cdc/connector-cdc-base/src/main/java/org/seatunnel/connectors/cdc/base/config/SourceConfig.java}
(62%)
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/seatunnel/connectors/cdc/base/option/SourceOptions.java
copy
seatunnel-connectors-v2/{connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/config/KafkaSemantics.java
=>
connector-cdc/connector-cdc-base/src/main/java/org/seatunnel/connectors/cdc/base/option/StartupMode.java}
(61%)
copy
seatunnel-api/src/main/java/org/apache/seatunnel/api/source/Boundedness.java =>
seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/seatunnel/connectors/cdc/base/option/StopMode.java
(67%)
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/seatunnel/connectors/cdc/base/source/IncrementalSource.java
copy
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/ActionSubtaskState.java
=>
seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/seatunnel/connectors/cdc/base/source/event/CompletedSnapshotSplitReportEvent.java
(81%)
copy
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/ActionSubtaskState.java
=>
seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/seatunnel/connectors/cdc/base/source/event/SnapshotSplitWatermark.java
(78%)
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/seatunnel/connectors/cdc/base/source/offset/Offset.java
copy
seatunnel-connectors-v2/{connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/schema/Schema.java
=>
connector-cdc/connector-cdc-base/src/main/java/org/seatunnel/connectors/cdc/base/source/offset/OffsetFactory.java}
(69%)
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/seatunnel/connectors/cdc/base/source/split/CompletedSnapshotSplitInfo.java
create mode 100644
seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/seatunnel/connectors/cdc/base/source/split/LogSplit.java
copy
seatunnel-connectors-v2/{connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/split/FileSourceSplit.java
=>
connector-cdc/connector-cdc-base/src/main/java/org/seatunnel/connectors/cdc/base/source/split/SnapshotSplit.java}
(58%)
copy
seatunnel-api/src/main/java/org/apache/seatunnel/api/serialization/DeserializationSchema.java
=>
seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/seatunnel/connectors/cdc/debezium/DebeziumDeserializationSchema.java
(61%)
copy {seatunnel-formats => seatunnel-connectors-v2/connector-cdc}/pom.xml (86%)
