flume執行流程

flume執行流程: source執行channel的doput方法,將接受到的event先放入putlist裏面臨時緩存起來,當到達必定的量(batchSize)的時候,執行docommit方法, 將putlist中的event放入channel的queue(queue的大小是capacity)中,當sink執行時,會調用channel的dotake方法,將取出的event放入到takelist
相關文章
相關標籤/搜索