普元数据开发平台 普元数据开发平台
产品介绍
安装部署
快速入门
操作指南
应用集成
FAQ
  • StarRocks输出组件使用说明
  • 组件说明
  • 配置项说明

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

← PARQUET输出 XML输出 →