Skip to main content

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配置的能力

输入流要求:

组件必须提供输入流。

系统资源考量:

未提供。