色魔王子7 发表于 2015-9-17 07:18:45

Flume 关于Event的笔记

  在Flume中使用Event对象来作为传递数据的格式。
  Sources端在flume-ng-core子项目中的org.apache.flume.serialization包下,有一个名为LineDeserializer的类,这个类负责把数据按行来读取,每一行封装成一个Event(实现方式:按字节读取,当遇到"\n"时封装成Event返回,下一次获取Event时继续获取下一字节并判断)。然后按用户设置的批量传输的值来封装List<Event>。
  未完,待续......
页: [1]
查看完整版本: Flume 关于Event的笔记