【Flume】HDFSSink源碼理解

HDFSSink組件中，主要由HDFSEventSink,BucketWriter,HDFSWriter幾個類構成。 其中HDFSEventSink主要功能呢是判定Sink的配置條件是否合法，並負責從Channel中獲取events，通過解析event的header信息決定event對應的BucketWriter。 BucketWriter負責按照rollCount,rollSize等條件在HDF

>>阅读原文<<