Flink Connector Kudu是基于Apache Bahir项目的Kudu Connector开发的一款专门用于连接Apache Flink与Google Kudu的流处理连接工具,简化了数据在实时应用中的高效存储和查询过程。
Kudu连接器是基于Apache Bahir Kudu连接器改造而来,并满足公司内部使用需求的版本。它支持范围分区特性、定义哈希分桶数等功能,并且兼容Flink 1.11.x动态数据源等特性。经过改进后,部分功能已回馈给社区。
在项目中使用该Kudu连接器时,请先克隆代码并根据公司私服环境调整pom文件坐标信息。创建目录的示例如下:
```java
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
catalog = new KuduCatalog(cdh01:7051,cdh02:7051,cdh03:7051);
tableEnv = KuduTableTestUtils.createTableEnvWithBlinkPlannerStreamingMode(env);
```