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);

示例代码

示例代码在此处