【文件属性】：
文件名称：flink-connector-kudu:基于Apache-bahir-kudu-connector的flink-connector-kudu，支持Flink1.11.x DynamicTableSourceSink，支持范围分区等
文件大小：162KB
文件格式：ZIP
更新时间：2021-03-04 17:45:49
kudu flink datastream flink-sql Java
Kudu连接器
基于Apache-Bahir-Kudu连接器改造而来的满足公司内部使用的Kudu连接器，支持特性范围分区，定义哈希分桶数，支持Flink1.11.x动态数据源等，改造后已贡献部分功能给社区。
使用姿势
clone代码后，改造pom项目坐标后上传公司私服使用
Kudu目录使用
创建目录
StreamExecutionEnvironment env = StreamExecutionEnvironment . getExecutionEnvironment();
catalog = new KuduCatalog ( " cdh01:7051,cdh02:7051,cdh03:7051 " );
tableEnv = KuduTableTestUtils . createTableEnvWithBlinkPlannerStreamingMode(env);
tableEnv .