在Flume中使用Event对象来作为传递数据的格式。
Sources端在flume-ng-core子项目中的org.apache.flume.serialization包下，有一个名为LineDeserializer的类，这个类负责把数据按行来读取，每一行封装成一个Event（实现方式：按字节读取，当遇到"\n"时封装成Event返回，下一次获取Event时继续获取下一字节并判断）。然后按用户设置的批量传输的值来封装List<Event>。
未完，待续......
免责声明！
本站转载的文章为个人学习借鉴使用，本站对版权不负任何法律责任。如果侵犯了您的隐私权益，请联系本站邮箱yoyou2525@163.com删除。
猜您在找
FLUME学习笔记--模拟Flume用户行为日志采集
keybd_event、SendInput笔记
Flume 问题 org.apache.flume.ChannelFullException: Space for commit to queue couldn't be acquired. Unable to deliver event. Exception follows
Flume(一)
flume
Libevent源码学习笔记一：event2/event.h
vue 笔记，ref 及 $event 事件对象
RTX笔记5 - 事件标志组 event flags
Hadoop学习笔记—19.Flume框架学习
【传智播客】Libevent学习笔记(四)：事件event