在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