You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ol...@apache.org on 2023/03/14 13:23:41 UTC
[rocketmq-connect] branch master updated (47889ea1 -> cdab185f)

This is an automated email from the ASF dual-hosted git repository.

oliverwqcwrw pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git


    from 47889ea1 [ISSUE #434]Fix CVE dependency issue (#435)
     add cdab185f [ISSUE #392] Add iotdb source connector (#398)

No new revisions were added by this update.

Summary of changes:
 connectors/rocketmq-connect-iotdb/README.md        |  30 +++++
 .../pom.xml                                        | 115 +++++++++---------
 .../connect/iotdb/config/IotdbConfig.java}         |  82 +++++++------
 .../connect/iotdb/config/IotdbConstant.java}       |  20 ++--
 .../connect/iotdb/config/SchemaProcessor.java      |  61 ++++++++++
 .../iotdb/connector/IotdbSourceConnector.java      |  89 ++++++++++++++
 .../connect/iotdb/connector/IotdbSourceTask.java   | 132 +++++++++++++++++++++
 .../iotdb/exception/IotdbRuntimeException.java}    |  10 +-
 .../iotdb/replicator/source/DeviceEntity.java      |  99 ++++++++++++++++
 .../iotdb/replicator/source/IotdbQuery.java        | 117 ++++++++++++++++++
 .../iotdb/replicator/source/IotdbReplicator.java}  |  38 +++---
 .../connect/iotdb/config/IotdbConfigTest.java}     |  19 ++-
 .../iotdb/connector/IotdbSourceConnectorTest.java  |  49 ++++++++
 .../iotdb/connector/IotdbSourceTaskTest.java       |  62 ++++++++++
 14 files changed, 780 insertions(+), 143 deletions(-)
 create mode 100644 connectors/rocketmq-connect-iotdb/README.md
 copy connectors/{rocketmq-connect-hive => rocketmq-connect-iotdb}/pom.xml (95%)
 copy connectors/{rocketmq-connect-mqtt/src/main/java/org/apache/rocketmq/connect/mqtt/config/ConnectorConfig.java => rocketmq-connect-iotdb/src/main/java/org/apache/rocketmq/connect/iotdb/config/IotdbConfig.java} (73%)
 copy connectors/{rocketmq-connect-cassandra/src/test/java/org/apache/rocketmq/connect/cassandra/common/TestClone.java => rocketmq-connect-iotdb/src/main/java/org/apache/rocketmq/connect/iotdb/config/IotdbConstant.java} (66%)
 create mode 100644 connectors/rocketmq-connect-iotdb/src/main/java/org/apache/rocketmq/connect/iotdb/config/SchemaProcessor.java
 create mode 100644 connectors/rocketmq-connect-iotdb/src/main/java/org/apache/rocketmq/connect/iotdb/connector/IotdbSourceConnector.java
 create mode 100644 connectors/rocketmq-connect-iotdb/src/main/java/org/apache/rocketmq/connect/iotdb/connector/IotdbSourceTask.java
 copy connectors/{rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/ErrorCode.java => rocketmq-connect-iotdb/src/main/java/org/apache/rocketmq/connect/iotdb/exception/IotdbRuntimeException.java} (76%)
 create mode 100644 connectors/rocketmq-connect-iotdb/src/main/java/org/apache/rocketmq/connect/iotdb/replicator/source/DeviceEntity.java
 create mode 100644 connectors/rocketmq-connect-iotdb/src/main/java/org/apache/rocketmq/connect/iotdb/replicator/source/IotdbQuery.java
 copy connectors/{rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/replicator/source/ElasticsearchReplicator.java => rocketmq-connect-iotdb/src/main/java/org/apache/rocketmq/connect/iotdb/replicator/source/IotdbReplicator.java} (62%)
 copy connectors/{rocketmq-connect-hive/src/test/java/org/apache/rocketmq/connect/hive/config/HiveConfigTest.java => rocketmq-connect-iotdb/src/test/java/org/apache/rocketmq/connect/iotdb/config/IotdbConfigTest.java} (65%)
 create mode 100644 connectors/rocketmq-connect-iotdb/src/test/java/org/apache/rocketmq/connect/iotdb/connector/IotdbSourceConnectorTest.java
 create mode 100644 connectors/rocketmq-connect-iotdb/src/test/java/org/apache/rocketmq/connect/iotdb/connector/IotdbSourceTaskTest.java