Flume 源碼解析：HDFS Sink

Apache Flume 數據流程的最後一部分是 Sink，它會將上游抽取並轉換好的數據輸送到外部存儲中去，如本地文件、HDFS、ElasticSearch 等。本文將通過分析源碼來展現 HDFS Sink 的工作流程。 Sink 組件的生命週期 在上一篇文章中, 我們瞭解到 Flume 組件都會實現 LifecycleAware 接口，並由 LifecycleSupervisor 實例管理和監控

>>阅读原文<<