特牛网址导航

Flume事务机制_flume的take和put_梦里Coding的博客-CSDN博客

网友收藏
Flume事务机制Flume事务机制Flume事务机制Flume事务有put和take机制,两者保证数据传输的准确性.Put事务:Source到ChanneldoPut:将数据从souce写入临时缓冲区putListdoCommit:检查Channel内存队列是否足够合并doRollback:channel 内存队列空间不足,则回滚数据take事务:channel到sinkdoTake:将数据取到临时缓冲区takeListdoCommit:如果数据全部发送成功,则清除临时缓冲区takeL_flume的take和put