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%)