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: 该操作用于删除符合条件的数据记录。需要指定删除的条件，满足该条件的所有记录都将被删除。