如果還沒(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