You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by ga...@apache.org on 2022/09/28 11:31:39 UTC
[incubator-seatunnel] branch dev updated (eaa979a2d -> 3da11ce19)

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 eaa979a2d [Improve][e2e] Unified e2e IT for Redis (#2924)
     add 3da11ce19 [Imporve][Connector-V2] Imporve iotdb connector (#2917)

No new revisions were added by this update.

Summary of changes:
 docs/en/connector-v2/sink/IoTDB.md                 | 143 ++++++++---
 docs/en/connector-v2/source/IoTDB.md               |  69 +++++-
 .../seatunnel/common/sink/AbstractSinkWriter.java  |   2 +-
 .../seatunnel/iotdb/config/SinkConfig.java         |  47 ++--
 .../seatunnel/iotdb/constant/SourceConstants.java  |   2 +
 .../serialize/DefaultSeaTunnelRowDeserializer.java | 107 ++++++++
 .../serialize/DefaultSeaTunnelRowSerializer.java   | 268 +++++++++++----------
 ...rializer.java => SeaTunnelRowDeserializer.java} |   6 +-
 .../seatunnel/iotdb/sink/IoTDBSinkClient.java      |   2 +-
 .../seatunnel/iotdb/sink/IoTDBSinkWriter.java      |  13 +-
 .../seatunnel/iotdb/source/IoTDBSource.java        |   2 +-
 .../seatunnel/iotdb/source/IoTDBSourceReader.java  |  83 +++----
 .../seatunnel/iotdb/source/IoTDBSourceSplit.java   |   3 +
 .../iotdb/source/IoTDBSourceSplitEnumerator.java   | 134 ++++++++---
 .../seatunnel/iotdb/state/IoTDBSourceState.java    |  19 +-
 .../e2e/flink/v2/iotdb/FakeSourceToIoTDBIT.java    | 128 ----------
 .../seatunnel/e2e/flink/v2/iotdb/IoTDBIT.java      | 209 ++++++++++++++++
 ...rce_to_iotdb.conf => iotdb_source_to_sink.conf} |  43 ++--
 .../e2e/spark/v2/iotdb/FakeSourceToIoTDBIT.java    | 127 ----------
 .../seatunnel/e2e/spark/v2/iotdb/IoTDBIT.java      | 208 ++++++++++++++++
 .../test/resources/iotdb/fakesource_to_iotdb.conf  |  41 ++--
 .../resources/iotdb/iotdb_source_to_sink.conf}     |  43 ++--
 22 files changed, 1099 insertions(+), 600 deletions(-)
 create mode 100644 seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/serialize/DefaultSeaTunnelRowDeserializer.java
 copy seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/serialize/{SeaTunnelRowSerializer.java => SeaTunnelRowDeserializer.java} (86%)
 delete mode 100644 seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-iotdb-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/iotdb/FakeSourceToIoTDBIT.java
 create mode 100644 seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-iotdb-flink-e2e/src/test/java/org/apache/seatunnel/e2e/flink/v2/iotdb/IoTDBIT.java
 copy seatunnel-e2e/seatunnel-flink-connector-v2-e2e/connector-iotdb-flink-e2e/src/test/resources/iotdb/{fakesource_to_iotdb.conf => iotdb_source_to_sink.conf} (50%)
 delete mode 100644 seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-iotdb-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/iotdb/FakeSourceToIoTDBIT.java
 create mode 100644 seatunnel-e2e/seatunnel-spark-connector-v2-e2e/connector-iotdb-spark-e2e/src/test/java/org/apache/seatunnel/e2e/spark/v2/iotdb/IoTDBIT.java
 rename seatunnel-e2e/{seatunnel-flink-connector-v2-e2e/connector-iotdb-flink-e2e/src/test/resources/iotdb/fakesource_to_iotdb.conf => seatunnel-spark-connector-v2-e2e/connector-iotdb-spark-e2e/src/test/resources/iotdb/iotdb_source_to_sink.conf} (50%)