Flume 源码解析:HDFS Sink

Apache Flume 数据流程的最后一部分是 Sink,它会将上游抽取并转换好的数据输送到外部存储中去,如本地文件、HDFS、ElasticSearch 等。本文将经过分析源码来展示 HDFS Sink 的工做流程。html Sink 组件的生命周期 在上一篇文章中, 咱们了解到 Flume 组件都会实现 LifecycleAware 接口,并由 LifecycleSupervisor 实例管
相关文章
相关标签/搜索