Flume組件source，channel，sink源碼分析

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();