当前位置:   article > 正文

20、Flink 数据写入 StarRocks_flinksql 使用gzip 压缩数据 然后保存到 starrocks

flinksql 使用gzip 压缩数据 然后保存到 starrocks
Flink 数据写入 StarRocks
引用:StarRocks官网:从 Apache Flink® 持续导入
目录:

常用参数

同Flink数据类型映射

一、概述
1)版本说明
组件版本
Flink1.14.6
StarRocks3.1.2
Scala2.11
2)写入 StarRocks 介绍

StarRocks 提供 flink-connector-starrocks,导入数据至 StarRocks,相比于 Flink 官方提供的 flink-connector-jdbc,导入性能更佳。 flink-connector-starrocks 的内部实现是通过缓存并批量由 Stream Load 导入。

注意

导入操作需要目标表的 INSERT 权限。

支持的数据源

CSV

JSON

常用参数
参数是否必填默认值数据类型描述
connectorString固定设置为 starrocks
jdbc-urlStringFE 的 MySQL Server 连接地址。格式为 jdbc:mysql://:
load-urlStringFE 的 HTTP Server 连接地址。格式为 :;:,可以提供多个地址,使用英文分号 (
声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/小小林熬夜学编程/article/detail/381318
推荐阅读
相关标签