如果還沒看過Flume-ng源碼解析之啟動流程,可以點(diǎn)擊Flume-ng源碼解析之啟動流程 查看
1 接口介紹
組件的分析順序是按照上一篇中啟動順序來分析的,首先是Channel,然后是Sink,最后是Source,在開始看組件源碼之前我們先來看一下兩個重要的接口,一個是LifecycleAware ,另一個是NamedComponent
1.1 LifecycleAware
@InterfaceAudience.Public@InterfaceStability.Stablepublic interface LifecycleAware { public void start(); public void stop(); public LifecycleState getLifecycleState(); }
非常簡單就是三個方法,start()、stop()和getLifecycleState,這個接口是flume好多類都要實(shí)現(xiàn)的接口,包括Flume-ng源碼解析之啟動流程
所中提到PollingPropertiesFileConfigurationProvider(),只要涉及到生命周期的都會實(shí)現(xiàn)該接口,當(dāng)然組件們也是要實(shí)現(xiàn)的!
1.2 NamedComponent
@InterfaceAudience.Public@InterfaceStability.Stablepublic interface&n