flume相关

flume相关

janice No Comment
未分类

flume主要有source  channel  sink

source —>  channel  —–>sink

流程粗略如上图.当然,source可以流入多个channel,   sink也可以从多个channel里面拉取数据.

source到channel会有  interceptor,可以过滤事件并添加一些数据进header.

之后会有一个selector.selector根据控制source具体要流到哪个channel.


1、selector

选择器可以工作在复制 多路复用(路由) 模式下
复制模式
属性说明:
selector.type replicating
selector.optional     多路复用(路由)模式
属性说明:
selector.type    multiplexing
selector.header    指定要监测的头的名称
selector.default    –
selector.mapping.*    –
栗子:
t1.sources = r1
t1.channels = c1 c2 c3 c4
t1.sources.r1.selector.type = multiplexing
t1.sources.r1.selector.header = country
t1.sources.r1.selector.mapping.CN = c1
t1.sources.r1.selector.mapping.US= c2 c3
t1.sources.r1.selector.default = c4

发表评论

分类目录

关于我

 Janice 詹

QQ   455899417

janice2014@foxmail.com