Flume-事务机制,Flume Agent内部原理

文章目录 Flume事务机制 Flume Agent内部原理 Flume事务机制 Put事务-流程 doPut:将批数据先写入临时缓冲区 putList doCommit:检查 channel 内存队列是否足够合并 doRollback:channel 内存队列空间不足,回滚数据 Take 事务流程 doTake:将数据取到临时缓冲区 takeList,并将数据发送到 HDFS doCommit:
相关文章
相关标签/搜索