PutDruidRecord
描述:
将记录发送到Druid并创建索引
标签:
druid, timeseries, olap, ingest, put, record, 记录, 发送
参数:
如下列表中，必填参数则标识为加粗. 其他未加粗参数，则表示为可选参数。表中同时提到参数默认值设置.
| 名字 | 默认值 | 允许值列表 | 描述 |
|---|---|---|---|
| 记录读取 | 控制器服务API: RecordReaderFactory 实现: ParquetReader GrokReader SyslogReader Syslog5424Reader CSVReader AvroReader JsonPathReader JsonTreeReader ScriptedReader XMLReader | 指定用于解析输入数据的读取服务并需要提供数据的Schema信息。 | |
| 记录输出 | 控制器服务API: RecordSetWriterFactory 实现: CSVRecordSetWriter FreeFormTextRecordSetWriter AvroRecordSetWriter JsonRecordSetWriter XMLRecordSetWriter ParquetRecordSetWriter ScriptedRecordSetWriter | 指定用于将数据序列化的输出服务 | |
| Tranquility服务 | 控制器服务API: DruidTranquilityService 实现: DruidTranquilityController | 用于发送到Druid的Tranquility服务 |
连线:
| 名字 | 描述 |
|---|---|
| success | 当数据被成功处理的数据流将输出到此连线 |
| dropped | 当数据处于时间窗口外，或时间戳格式不正确等等因素，将导致数据输出到此连线 |
| failure | 当不能被Druid解析或以其他方式处理的数据输出到此失败连线 |
读取属性:
未提供。
写入属性:
| 名字 | 描述 |
|---|---|
| record.count | 发送到Druid的数据流中的消息数。通过该参数可知Druid成功处理了多少数据。同样该属性在失败和丢弃连线上也有类似作用。 |
状态管理:
该组件不保存状态。
限制:
该组件没有限制
输入流要求:
组件必须提供输入流。
系统资源考量:
未提供。