This is an automated email from the ASF dual-hosted git repository.
kirs pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
from fd12a127d [Improve][seatunnel-engine-common] move serializer to common
(#3818)
add 8e3d158c0 [Feature][Connector-v2][StarRocks] Support write cdc
changelog event(INSERT/UPDATE/DELETE) (#3865)
No new revisions were added by this update.
Summary of changes:
docs/en/connector-v2/sink/StarRocks.md | 57 +++++---
docs/en/connector-v2/source/FakeSource.md | 74 ++++++++++
seatunnel-connectors-v2/connector-fake/pom.xml | 5 +
.../seatunnel/fake/config/FakeConfig.java | 27 ++++
.../seatunnel/fake/config/FakeOption.java | 5 +
.../seatunnel/fake/source/FakeDataGenerator.java | 29 +++-
.../seatunnel/fake/source/FakeSourceFactory.java | 15 +-
.../fake/source}/FakeDataGeneratorTest.java | 27 ++++
.../src/test/resources/fake-data.schema.conf | 53 ++++---
.../seatunnel/starrocks/config/SinkConfig.java | 9 ++
.../serialize/StarRocksBaseSerializer.java | 12 +-
.../serialize/StarRocksCsvSerializer.java | 14 +-
.../serialize/StarRocksJsonSerializer.java | 10 +-
...rRocksISerializer.java => StarRocksSinkOP.java} | 23 ++-
.../starrocks/sink/StarRocksSinkFactory.java | 2 +-
.../starrocks/sink/StarRocksSinkWriter.java | 9 +-
.../connector-starrocks-e2e/pom.xml | 2 +-
.../connector/starrocks/StarRocksCDCSinkIT.java | 154 +++++++++++++++++++++
.../resources/starrocks-jdbc-to-starrocks.conf | 7 +-
....conf => write-cdc-changelog-to-starrocks.conf} | 56 ++++++--
.../format/json/JsonDeserializationSchema.java | 19 +++
.../seatunnel/format/json/JsonToRowConverters.java | 9 +-
22 files changed, 537 insertions(+), 81 deletions(-)
rename
seatunnel-connectors-v2/connector-fake/src/test/java/{org.apache.seatunnel.connectors.seatunnel.fake.source
=>
org/apache/seatunnel/connectors/seatunnel/fake/source}/FakeDataGeneratorTest.java
(71%)
copy
seatunnel-e2e/seatunnel-engine-e2e/connector-console-seatunnel-e2e/src/test/resources/fakesource_to_console.conf
=>
seatunnel-connectors-v2/connector-fake/src/test/resources/fake-data.schema.conf
(56%)
copy
seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/serialize/{StarRocksISerializer.java
=> StarRocksSinkOP.java} (57%)
create mode 100644
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-starrocks-e2e/src/test/java/org/apache/seatunnel/e2e/connector/starrocks/StarRocksCDCSinkIT.java
copy
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-starrocks-e2e/src/test/resources/{starrocks-jdbc-to-starrocks.conf
=> write-cdc-changelog-to-starrocks.conf} (52%)
