Flume示例FlumeFlume Put事务和Take事务曦2025-01-132025-01-1312345678910111213141516171819在source和chanel的传输中是批量过去的,channels传输到sinks也是批量的在source到channel中呢就有一个缓冲区1.doPut操作,浆皮数据写入到临时缓冲区 Putlist中2.doCommit操作:检查channel队列中是否有足够空间用来存放数据 有的话就会执行doCommit操作3.如果channel空间不够就会执行回滚数据的操作(doRollBack)在channel到sink中的事务叫take事务,也是批量过去的1.doTake操作,拉取一批channel的数据,然后进入缓冲区2.takeList操作,临时缓冲3.doCommit操作,将这一批数据发送出去,发送失败就会回滚4.doRollBack发送失败就进行回滚