在上一篇,我们从使用方式和策略上,对消息队列做了一个宏观描述。从本篇开始,我们将深入到源码内部,仔细分析Kafka到底是如何实现一个分布式消息队列。我们的分析将从Produc...
IP属地:福建
在上一篇,我们从使用方式和策略上,对消息队列做了一个宏观描述。从本篇开始,我们将深入到源码内部,仔细分析Kafka到底是如何实现一个分布式消息队列。我们的分析将从Produc...
上一节我们详细解析了生产端在发消息的dosend()里,首先是拉取元数据信息,在拉取过程中,先唤醒了sender线程,接着主线程进入等待状态,直到sender线程拉取元数据成...
简介 kudu官网https://kudu.apache.org/ 准备 直接通过yum install是找不到kudu的源的,在官网安装的页面详细介绍了怎么在各种系统下安装...
上一节我们是不是讲到,Driver,Application注册到Master上面后,Master中调用scheduler()进行资源调度,在这个里面通过LaunchDrive...
在hive中有metaServer与hiveServer2两种服务,看了好多文章说这两个的区别,文章内容有对有错,不够全面,故在这里好好总结一下。 首先,下面这个hive构架...
前面三章我们已经尝试剖析讲过SparkContext的基本的原理,其实涉及到了Driver对Master的注册,本节就关于Master注册机制进行更详细的剖析。 我们知道Sp...
前面我们讲过了了关于spark整体构架原理,在spark中 ,当执行我们的application,也就是我们写的程代码,我们回想一下,之前我们写的spark应用的第一行是不是...