Skip to main content

PutKudu

概述

该组件将使用配置的记录服务从输入数据流中读取记录,并写入到指定的Kudu服务的表中。该表名的schema必须在组件的属性中设置,或在源中设置。如果读取记录时出错,或者写入到Kudu时出错,数据流将被作为异常处理。

说明:目前该组件使用org.apache.kudu.kudu-client-1.7.0版本对接,存在部分Kudu服务端不能正常使用。

PutDruidRecord属性说明

Kudu 主节点 : 列出所有Kudu主节点的ip和端口组合,如果需要,请使用逗号分隔。
表名 :数据将要存入到的Kudu表名
记录服务 :该服务将从流入的流文件中读取记录,指定用于解析输入数据的读取服务并需要提供数据的Schema信息。

示例

例子中,我们将样本数据Json插入到Kudu系统的demo表中。

demo

#####样本数据

{"name":"张三","age":"18"}

#####设置

设置Kudu主机点信息,也就是要访问的Kudu服务信息。要插入数据的表名。

properties

根据处理的上级数据的格式需要配置记录读取的类型,比如这里上级是Json数据,配置JsonTreeReader。

流程模板

参见附件(请右键另存保存):PutKudu示例