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