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