首页 > 代码库 > Flume 关于Event的笔记

Flume 关于Event的笔记

  在Flume中使用Event对象来作为传递数据的格式。

  Sources端在flume-ng-core子项目中的org.apache.flume.serialization包下,有一个名为LineDeserializer的类,这个类负责把数据按行来读取,每一行封装成一个Event(实现方式:按字节读取,当遇到"\n"时封装成Event返回,下一次获取Event时继续获取下一字节并判断)。然后按用户设置的批量传输的值来封装List<Event>。

  未完,待续......

Flume 关于Event的笔记