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

網(wǎng)友評論