Skip to content

Doris输出组件使用说明 ​

组件说明 ​

Doris 输出组件用于向Doris数据源写入数据。

说明:需要提前在数据库创建好表,目前不支持运行时自动创建表。

配置项说明 ​

配置名称数据类型是否必须默认值描述
节点名称String是-当前创建的节点名称,由用户自定义且不可为空。命名可包含字母、数字、下划线。
选择数据源String是-当前输入绑定的数据源名称,从下拉选项中列出的指定的关联类型的数据源进行选择。
库名称String是-选定的来源库。
表名称String是-选定的来源表。
标签前缀String是-StreamLoad提交时的唯一标识,如果不填写系统会自动生成一个UUID。
启用两阶段提交Boolean是false用于确保分布式事务的原子性。它被用来确保在分布式环境中,所有参与的节点要么都成功提交事务,要么都回滚,避免部分提交的情况发生。
是否启用删除Boolean是false删除所有与导入数据 key 列值相同的行。该选项需要 Doris 表开启批量删除功能 (默认开启 0.15+ 版本),且只支持 Unique 表模型。
最大缓存记录Integer是30000在尝试重试StarRocks请求之前等待的时间。
最大缓存大小Integer是false每次操作前,先把目标表清空。
写入格式String是写入数据的格式
数据格式String是批量提交或则单一提交
写入超时时间Integer是发送数据写入的请求后等待返回的超时时间。
提交记录数量Integer是1每次提交数据的数量
Stream LoadInteger是-流加载模式的参数。StarRocks sink连接器的内部实现是通过流加载批量缓存和导入的。
字段设置-是-来源字段:上游字段传入的字段名。目标字段:根据选择的数据源及目标表,展示输出字段。

FAQ ​

无