赞
踩
组件 | 版本 |
---|---|
Flink | 1.14.6 |
StarRocks | 3.1.2 |
Scala | 2.11 |
StarRocks 提供 flink-connector-starrocks,导入数据至 StarRocks,相比于 Flink 官方提供的 flink-connector-jdbc,导入性能更佳。 flink-connector-starrocks 的内部实现是通过缓存并批量由 Stream Load 导入。
注意
导入操作需要目标表的 INSERT 权限。
CSV
参数 | 是否必填 | 默认值 | 数据类型 | 描述 |
---|---|---|---|---|
connector | 是 | 无 | String | 固定设置为 starrocks 。 |
jdbc-url | 是 | 无 | String | FE 的 MySQL Server 连接地址。格式为 jdbc:mysql://: 。 |
load-url | 是 | 无 | String | FE 的 HTTP Server 连接地址。格式为 :;: ,可以提供多个地址,使用英文分号 (声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/小小林熬夜学编程/article/detail/381318 推荐阅读 相关标签 Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。 |