StarRocks数据导入--Flink Connector与CDC秒级数据同步 大数据

StarRocks数据导入--Flink Connector与CDC秒级数据同步

Flink作为当前流行的流式计算框架,在对接StarRocks时,若直接使用JDBC的方式“流式”写入数据,对StarRocks是不友好的,StarRocks作为一款MVCC的数据库,其导入的核心思想还是“攒微批+降频率”。为此,StarRocks单独开发了flink-connector-starrocks,其内部实现仍是通过对数据缓存攒批后执行Stream Load导入。 StarRock...
阅读全文
Loading...