Skip to content

Commit

Permalink
Update README.md
Browse files Browse the repository at this point in the history
  • Loading branch information
collabH authored Jan 5, 2022
1 parent acf037c commit 8aa9400
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion README.md
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
[![flink-connector-kudu](https://github.com/collabH/flink-connector-kudu/actions/workflows/maven.yml/badge.svg?branch=master)](https://github.com/collabH/flink-connector-kudu/actions/workflows/maven.yml)
# Kudu Connector

* 基于Apache-Bahir-Kudu-Connector改造而来的满足公司内部使用的Kudu Connector,支持特性Range分区、定义Hash分桶数、支持Flink1.11.x动态数据源等,改造后已贡献部分功能给社区。
Expand Down Expand Up @@ -144,4 +145,4 @@ CREATE TABLE TestTableKuduDynamicTableSource (
## 1.2版本Feature

* 改造支持`Flink 1.11.x`之后的`DynamicSource/Sink`,以此解决SQL语句主键无法推断问题,支持流批JOIN功能的SQL语句方式,无需在通过转换成DataStream的方式进行多表Join操作。
* 内嵌Metrics上报机制,通过对`Flink`动态工厂入口处对操作的kudu表进行指标埋点,从而更加可视化的监控kudu表数据上报问题。
* 内嵌Metrics上报机制,通过对`Flink`动态工厂入口处对操作的kudu表进行指标埋点,从而更加可视化的监控kudu表数据上报问题。

0 comments on commit 8aa9400

Please sign in to comment.