liunaijie commented on code in PR #5404:
URL: https://github.com/apache/seatunnel/pull/5404#discussion_r1311188685
##########
docs/en/connector-v2/sink/IoTDB.md:
##########
@@ -68,77 +68,46 @@ There is a conflict of thrift version between IoTDB and
Spark.Therefore, you nee
| connection_timeout_in_ms | Integer | No | -
| The maximum time (in ms) to wait when connecting to `IoTDB`
|
| common-options | | no | -
| Sink plugin common parameters, please refer to [Sink Common
Options](common-options.md) for details
|
-## Task Example
-
-### Case1
-
-Common options:
+## Examples
```hocon
-sink {
- IoTDB {
- node_urls = ["localhost:6667"]
- username = "root"
- password = "root"
- batch_size = 1024
- }
+env {
+ execution.parallelism = 2
+ job.mode = "BATCH"
}
-```
-When you assign `key_device` is `device_name`, for example:
-
-```hocon
-sink {
- IoTDB {
- ...
- key_device = "device_name"
+source {
+ FakeSource {
+ row.num = 16
+ schema = {
+ fields {
+ device_name = "string"
+ temperature = "float"
+ moisture = "bigint"
+ }
+ }
}
}
-```
-Upstream SeaTunnelRow data format is the following:
Review Comment:
the sink example, I only add 1 case (fakesource to iotdb)(also 1 case in
source example, use iotdb to console)
the key_timestamp is optional, so i remove it.
for example data, remove some filed to keep consistent with example code.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
