Flink 连接器
该连接器提供了 sink ,可以把数据发送到CnosDB。
依赖需求
需要 CnosDB 2.1.0 以上版本。 需要 Java 1.8 以上版本。
首先添加依赖到您的项目中:
<dependency>
<groupId>com.cnosdb</groupId>
<artifactId>flink-connector-cnosdb</artifactId>
<version>1.0</version>
</dependency>
代码说明
创建 CnosDB 配置
CnosDBConfig cnosDBConfig = CnosDBConfig.builder()
.url("http://localhost:8902")
.database("db_flink_test")
.username("root")
.password("")
.build();
创建 CnosDBSink 并添加到 Stream 的 Sink 中。
dataStream.addSink(new CnosDBSink(cnosDBConfig);
CnosDBSink 接受的是 CnosDBPoint 类,该类其实就是 LineProtocol 格式的代码实现。
new CnosDBPoint(measurement, timestamp, tags, fields);
示例代码
示例代码在此处