Flume系列3-Flume事务与传输流程

文章目录
一. Flume 事务二. Flume 传输流程参考:

一. Flume 事务
流程图：
Put 事务流程: doPut：将批数据先写入临时缓冲区 putList doCommit：检查 channel 内存队列是否足够合并 doRollback：channel 内存队列空间不足，回滚数据
Take 事务流程: doTake：将数据取到临时缓冲区 takeList，并将数据发送到 HDFS doCommit：如果数据全部发送成功，则清除临时缓冲区 takeList doRollback：数据发送过程中如果出现异常，rollback 将临时缓冲区 takeList 中的数据归还给 channel 内存队列
二. Flume 传输流程
流程图:
重要组件： 4）Channel Selector Channel Selector 的作用就是选出 Event 将要被发往哪个 Cha

Flume系列3-Flume事务与传输流程最先出现在Python成神之路。