请教flink-sql-iotdb-connector连接器写入iotdb的sql案例
- Ngôn ngữ chính
- Java
- Star
- 6.4k
- Fork
- 1.2k
- Merge trung bình
- 1 ngày 23 giờ
- Pull request đã merge (30 ngày)
- 115
Mô tả
请问下: 看文档介绍从1.2开始支持flinksql的连接器了,但是无法引入该jar
```
org.apache.iotdb
flink-sql-iotdb-connector
${iotdb.version}
```
maven仓库没有该jar?这个jar如何引入。
另外,flink-sql-iotdb-connector 的sql形式案例有没有?例如:
```
`-- register a MySQL table 'users' in Flink SQL
CREATE TABLE MyUserTable (
id BIGINT,
name STRING,
age INT,
status BOOLEAN,
PRIMARY KEY (id) NOT ENFORCED
) WITH (
'connector' = 'jdbc',
'url' = 'jdbc:mysql://localhost:3306/mydatabase',
'table-name' = 'users'
);`
```
那么想从kafka消费数据写入iotdb,请问怎么写呢?谢谢
Hướng dẫn đóng góp
Hướng nghiên cứu
Bắt đầu bằng cách kiểm tra dependency flink-sql-iotdb-connector đã được ghi lại và tài liệu connector Flink SQL hiện có. Xác nhận rằng artifact có thể được resolve và ghi lại một ví dụ Kafka-to-IoTDB SQL, bao gồm dependency coordinates và một lần chạy end-to-end thành công.
Do mô hình lập chỉ mục viết ra từ nội dung của issue.
Đánh giá
- Công nghệ
- java, kafka, sql
- Lĩnh vực
- databases, documentation, stream-processing
- Loại issue
- Tài liệu
- Độ khó
- 4/5
- Thời gian dự kiến
- 3-5 ngày
- Mức độ hoạt động
- Đình trệ
- Độ rõ ràng
- Cần làm rõ
- Mức phù hợp với người mới
- 25/100