You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by ki...@apache.org on 2023/01/12 02:08:27 UTC
[incubator-seatunnel] branch dev updated (fd12a127d -> 8e3d158c0)
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%)