Flume OG自带sink、source、collector

# Flume OG自带Source
console                      监听用户编辑历史和快捷键输入,只在node_nowatch模式下可用
stdin                        监听标准输入,只在node_nowatch模式下可用,每行将作为一个event source
rpcSource(port)              由rpc框架(thrift/avro)监听tcp端口
text("filename")             一次性读取一个文本,每行为一个event
tail("filename"[, startFromEnd=false])每行为一个event。监听文件尾部的追加行,如果startFromEnd为true,tail将从文件尾读取,如果为false,tail将从文件开始读取全部数据
multitail("filename"[, file2 [,file3… ] ]) 同上,同时监听多个文件的末尾
tailDir("dirname"[, fileregex=".*"[, startFromEnd=false[, recurseDepth=0]]])  监听目录中的文件末尾,使用正则去选定需要监听的文件(不包含目录),recurseDepth为递归监听其下子目录的深度

0 个评论

要回复文章请先登录注册