flume源码剖析之关键数据结构
本文是flume源码剖析系列的第一篇,主要关注flume的大概设计实现及主要流程,具体细节会在后续进行探究。
channel->sink简单流程
from TestKafkaSink.java
本文是flume源码剖析系列的第一篇,主要关注flume的大概设计实现及主要流程,具体细节会在后续进行探究。
from TestKafkaSink.java
C: (consistency)强一致性
A: (Availability)可用性
P: (Partition Tolerance)分区容忍性
A:(Atomicity)原子性
C:(Consitency)一致性
I:(Isolation)事物独立性
D:(Durability)持久性
单机存储引擎就是哈希表,B树等数据结构在机械磁盘,SSD等持久化介质上的实现。
flume最新release版本是1.6.0
官方介绍:
Flume is a distributed, reliable, and available service for efficiently collecting, aggregating, and moving large amounts of log data. It has a simple and flexible architecture based on streaming data flows. It is robust and fault tolerant with tunable reliability mechanisms and many failover and recovery mechanisms. It uses a simple extensible data model that allows for online analytic application.
Welcome to Hexo! This is your very first post. Check documentation for more info. If you get any problems when using Hexo, you can find the answer in troubleshooting or you can ask me on GitHub.
1 | $ hexo new "My New Post" |
More info: Writing
1 | $ hexo server |
More info: Server
1 | $ hexo generate |
More info: Generating
1 | $ hexo deploy |
More info: Deployment