Flume-事務機制,Flume Agent內部原理

文章目錄 Flume事務機制 Flume Agent內部原理 Flume事務機制 Put事務-流程 doPut:將批數據先寫入臨時緩衝區 putList doCommit:檢查 channel 內存隊列是否足夠合併 doRollback:channel 內存隊列空間不足,回滾數據 Take 事務流程 doTake:將數據取到臨時緩衝區 takeList,並將數據發送到 HDFS doCommit:
相關文章
相關標籤/搜索