Flume 自定义 Source-CSDN博客网友收藏

Flume 定义 Source-CSDN博客

Source 是负责接收数据到 Flume Agent 的组件Source 组件可以处理各种类型、各种格式的日志数据,包括 avro、thrift、exec、jms、spooling directory、netcat、sequence generator、syslog、http、legacy官方提供的 Source 类型已经很多,但是有时候并不能......
阅读全文
《大数据: Flume 自定义Sink》-CSDN博客网友收藏

《大数据: Flume 定义Sink》-CSDN博客

一、Flume 自定义Sink官方自定义sink的接口:https://flume.apache.org/FlumeDeveloperGuide.html#sinkMySink需要继承AbstractSink类并实现Configurable接口实现相应方法:configure(Context context) //初始化context(读取配置文件内容)process() //从Channel读取获取......
阅读全文