请教flink-sql-iotdb-connector连接器写入iotdb的sql案例
- Vorherrschende Sprache
- Java
- Sterne
- 6.4k
- Forks
- 1.2k
- Ø Merge
- 1 T. 23 Std.
- Gemergte PRs (30 T.)
- 115
Beschreibung
请问下: 看文档介绍从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,请问怎么写呢?谢谢
Beitragsleitfaden
Rechercherichtung
Beginne damit, die dokumentierte Abhängigkeit flink-sql-iotdb-connector und die vorhandene Dokumentation zum Flink-SQL-Connector zu prüfen. Bestätige, dass das Artifact aufgelöst werden kann, und dokumentiere ein Kafka-to-IoTDB-SQL-Beispiel einschließlich der Dependency-Koordinaten und eines erfolgreichen End-to-End-Laufs.
Vom Indexierungsmodell aus dem Issue-Text verfasst.
Bewertung
- Tech-Stack
- java, kafka, sql
- Bereich
- databases, documentation, stream-processing
- Issue-Typ
- Dokumentation
- Schwierigkeit
- 4/5
- Geschätzter Aufwand
- 3-5 Tage
- Aktivitätsstatus
- Veraltet
- Klarheit
- Muss geklärt werden
- Anfängerfreundlichkeit
- 25/100