请教flink-sql-iotdb-connector连接器写入iotdb的sql案例
オープン
- 主要言語
- Java
- スター
- 6.4k
- フォーク
- 1.2k
- 平均マージ
- 1日 23時間
- マージ済み PR(30日)
- 115
説明
请问下: 看文档介绍从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,请问怎么写呢?谢谢
コントリビューションガイド
調査の方向性
まず、記載されている flink-sql-iotdb-connector 依存関係と、既存の Flink SQL connector ドキュメントを確認します。artifact を解決できることを確認し、依存関係の coordinates と、エンドツーエンドで正常に実行できる Kafka-to-IoTDB SQL の例をドキュメント化します。
索引モデルが issue の本文から書いたものです。
評価
- 技術スタック
- java, kafka, sql
- 領域
- databases, documentation, stream-processing
- issue の種類
- ドキュメント
- 難易度
- 4/5
- 見積もり時間
- 3〜5日
- 活発さ
- 停滞
- 明瞭さ
- 説明が足りない
- 初心者へのやさしさ
- 25/100