# StarRocks输出组件使用说明
# 组件说明
StarRocks 输出组件用于向StarRocks数据源写入数据。
# 配置项说明
配置名称 | 数据类型 | 是否必须 | 默认值 | 描述 |
---|---|---|---|---|
节点名称 | String | 是 | - | 当前创建的节点名称,由用户自定义且不可为空。命名可包含字母、数字、下划线。 |
选择数据源 | String | 是 | - | 当前输入绑定的数据源名称,从下拉选项中列出的指定的关联类型(StarRocks)的数据源进行选择。 |
库名称 | String | 是 | - | 选定的来源库。 |
表名称 | String | 是 | - | 选定的来源表。 |
格式 | String | 是 | CSV | 使用什么格式导入数据,可选“CSV”或“JSON”。 |
列分隔符 | String | 是 | - | CSV导入列分隔符。(格式为“CSV”时需配置) 使用StreamLoad CSV导入,此处可配置CSV导入列分隔符,默认\t,如使用默认值请不要在此显式指定。如果您的数据中本身包含\t,则需自定义使用其他字符作为分隔符。 |
单次最大导入 | Integer | 是 | 64 | 对于批处理写入,当缓冲区达到最大导入数时,数据将被刷新到 StarRocks 中。 |
刷新频率 | Integer | 是 | 30 | 刷新失败的重试次数。 |
StarRocks 连接超时时间 | Integer | 是 | 30000 | 在尝试重试StarRocks请求之前等待的时间。 |
truncate表 | Boolean | 是 | false | 每次操作前,先把目标表清空。 |
Stream Load | Integer | 是 | - | 流加载模式的参数。StarRocks sink连接器的内部实现是通过流加载批量缓存和导入的。 |
字段设置 | - | 是 | - | 来源字段:上游字段传入的字段名。目标字段:根据选择的数据源及目标表,展示输出字段。 |
是否支持部分导入 | Boolean | 是 | true | 仅支持主键表更新。 |
更新模式 | String | 是 | UPSERT | UPSERT: 该操作用于插入或更新数据。如果数据已存在(基于主键/唯一键),它将更新该数据;如果数据不存在,它将插入新数据。DELETE: 该操作用于删除符合条件的数据记录。需要指定删除的条件,满足该条件的所有记录都将被删除。 |