标签:des io 使用 数据 on line 用户 对象 项目
在Flume中使用Event对象来作为传递数据的格式。
Sources端在flume-ng-core子项目中的org.apache.flume.serialization包下,有一个名为LineDeserializer的类,这个类负责把数据按行来读取,每一行封装成一个Event(实现方式:按字节读取,当遇到"\n"时封装成Event返回,下一次获取Event时继续获取下一字节并判断)。然后按用户设置的批量传输的值来封装List<Event>。
未完,待续......
标签:des io 使用 数据 on line 用户 对象 项目
原文地址:http://www.cnblogs.com/zhangyukun/p/4018513.html