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

巴特西