ExecuteFlumeSink
描述:
执行Flume Sink,每个输入数据流将被转换到Flume中作为Sink被处理。
标签:
flume, hadoop, put, sink, 写入
参数:
如下列表中,必填参数则标识为加粗. 其他未加粗参数,则表示为可选参数。表中同时提到参数默认值设置.
名字 | 默认值 | 允许值列表 | 描述 |
---|---|---|---|
Sink类型 | Sink的组件名,针对一些Sinks,这是个简称或符合,比如hdfs。对于其他,可能是Sink类的全名,可查看Flume用户手册获得更多信息。 | ||
代理名字 | tier1 | 用于Flume Sink配置的代理名 | |
Sink名字 | sink-1 | 用于Flume Sink配置的Sink名 | |
Flume配置 | 拷贝自flume.properties文件用于Sink的Flume配置 |
连线:
名字 | 描述 |
---|---|
success | 成功将输入数据流输出到Flume的数据将输出到此连线 |
failure | 由于某种原因导致输出到Flume失败而回滚的数据将输出到此连线 |
读取属性:
未提供。
写入属性:
未提供。
状态管理:
该组件不保存状态。
限制:
要求权限 | 说明 |
---|---|
执行代码 | 在假定平台拥有所有权限下,提供可以执行任意Flume配置的能力 |
输入流要求:
组件必须提供输入流。
系统资源考量:
未提供。