davidzollo commented on code in PR #9872:
URL: https://github.com/apache/seatunnel/pull/9872#discussion_r2375792380
##########
docs/en/connector-v2/source/IoTDBv2.md:
##########
@@ -0,0 +1,217 @@
+import ChangeLog from '../changelog/connector-iotdb.md';
+
+# IoTDB
+
+> IoTDB source connector
+
+## Description
+
+Used to read data from IoTDB.
+
+## Key features
+
+- [x] [batch](../../concept/connector-v2-features.md)
+- [x] [stream](../../concept/connector-v2-features.md)
+- [x] [exactly-once](../../concept/connector-v2-features.md)
+- [x] [column projection](../../concept/connector-v2-features.md)
+ > IoTDB allows column projection using SQL query.
+- [x] [parallelism](../../concept/connector-v2-features.md)
+- [ ] [support user-defined split](../../concept/connector-v2-features.md)
+
+## Supported DataSource Info
+
+| Datasource | Supported Versions | Url |
+|------------|--------------------|----------------|
+| IoTDB | `2.0 <= version` | localhost:6667 |
+
+## Data Type Mapping
+
+| IotDB Data Type | SeaTunnel Data Type |
+|-----------------|---------------------|
+| BOOLEAN | BOOLEAN |
+| INT32 | TINYINT |
+| INT32 | SMALLINT |
+| INT32 | INT |
+| INT64 | BIGINT |
+| FLOAT | FLOAT |
+| DOUBLE | DOUBLE |
+| TEXT | STRING |
+| STRING | STRING |
+| TIMESTAMP | BIGINT |
+| TIMESTAMP | TIMESTAMP |
+| BLOB | STRING |
+| DATE | DATE |
+
+## Source Options
+
+| Name | Type | Required | Default Value |
Description
|
+|----------------------------|---------|----------|---------------|-------------------------------------------------------------------------------------------------------------------|
+| node_urls | string | Yes | - | IoTDB
cluster address, the format is `"host1:port"` or `"host1:port,host2:port"`
|
+| username | string | Yes | - | IoTDB
username
|
+| password | string | Yes | - | IoTDB user
password
|
+| sql_dialect | string | No | tree | The sql
dialect of IoTDB, options available is `"tree"` or `"table"`
|
+| database | string | No | - | The
database selected (only valid when `sql_dielct` is `"table"`)
|
+| sql | string | Yes | - | The sql
statement to be executed
|
+| schema | config | Yes | - | The data
schema
|
+| fetch_size | int | No | - | The
fetch_size of the IoTDB when you select
|
+| lower_bound | long | No | - | The
lower_bound of the IoTDB when you select
|
+| upper_bound | long | No | - | The
upper_bound of the IoTDB when you select
|
+| num_partitions | int | No | - | The
num_partitions of the IoTDB when you select
|
+| thrift_default_buffer_size | int | No | - | The
thrift_default_buffer_size of the IoTDB when you select
|
Review Comment:
I noticed that parameter `thrift_default_buffer_size` is used in source, but
`thrift_default_buffer_size ` in sink, I think the same parameter will be
better.
--
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]
