flink connector kudu:基于Apache bahir kudu connector的flink connector kudu支持Flink1.
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 .
用户评论
