你的位置:首页 > 软件开发 > 数据库 > Flume组件source,channel,sink源码分析

Flume组件source,channel,sink源码分析

发布时间:2016-12-02 16:00:32
LifeCycleState:IDLE, START, STOP, ERROR [Source]: org.apache.flume.Source 继承LifeCycleAware{stop() + start() + getL ...

LifeCycleState:

IDLE, START, STOP, ERROR

 

[Source]: org.apache.flume.Source

         继承LifeCycleAware{stop() + start() + getLifeCycleState()} + NamedComponent{getName() + setName()}

         产生事件(Event),调用通道处理器(ChannelProcessor)的方法,将事件(Event)持久化到通道(Channel)中。

 

[Channel]: org.apache.flume.Channel

         继承LifeCycleAware{stop() + start() + getLifeCycleState()} + NamedComponent{getName() + setName()}

         将source(Event生产者)和sink(Event消费者)进行关联,Channel本是一个缓存(buffer),通道是线程安全的。

         put(Event e);                                                   //向Channel中放置事件(Event)

    take();                                                            //从Channel中提取事件(Event)

         Transaction getTransaction()                          //获取Channel事务

 

[Sink]: org.apache.flume.Sink

         继承LifeCycleAware{stop() + start() + getLifeCycleState()} + NamedComponent{getName() + setName()}

         连接到Channel,消费内容,发送给目的地。

         可以按照行为进行分组化(SinkGroup | SinkProcessor)

         Channel getChannel();

         setChannel(Channel ch);

         Status process();

Flume组件source,channel,sink源码分析

 


原标题:Flume组件source,channel,sink源码分析

关键词:

*特别声明:以上内容来自于网络收集,著作权属原作者所有,如有侵权,请联系我们: admin#shaoqun.com (#换成@)。

可能感兴趣文章

我的浏览记录