2018-11-08

Hbase源码10_插曲StealJobQueue

[TOC] Hbase源码10_插曲StealJobQueue1. 简介在HBase做Compact过程, 会分两个线程池来处理大Compact和小Compact, 用的就是StealJobQueue队列, 设计的挺巧, 可以看下。 大致思路如下： StealJobQueue本

2018-11-07

Hbase源码09_Split过程

[TOC] Hbase源码09_Split过程1. 简介在上节 MemStore -> HFile 的flush完成之后, 会判断是否需要对HFile进行 Split 或者 Compact。下面对Split的过程做简单的分析。 注: Cannot split meta

2018-10-12

Mac编译Hadoop和安装Native lib

Mac编译Hadoop和安装Native lib在mac系统中想要为hadoop添加snappy的支持，需要手动重新编译hadoop源码。 戳下面的链接 👉 Hadoop native libraries not found on OS/X 注意事项 报 protobuf

2018-09-28

使用 Reactor 进行反应式编程

使用 Reactor 进行反应式编程反应式编程（Reactive Programming）这种新的编程范式越来越受到开发人员的欢迎。在 Java 社区中比较流行的是 RxJava 和 RxJava 2。本文要介绍的是另外一个新的反应式编程库 Reactor。 反应式编程介绍反应式

2018-07-15

Hbase源码08_MemStore刷新到HFile

[TOC] Hbase源码08_MemStore刷新到HFile1. PUT 最后的代码在PUT代码解析的最后，当MemStore写入到一定的阀值，就会将数据flushing到HFile中，代码如下： 1234567891011 ...... ......} fin

2018-07-02

Hbase源码07_HMaster启动

[TOC] Hbase源码07_HMaster启动1. shell启动在执行 start-hbase.sh 这里就不扯了，主要代码如下，可以进对应的脚本看下： 123456789101112131415if [ "$distMode" == 'false' ] then "$b

2018-06-24

Hbase源码06_Delete

[TOC] Hbase源码06_Delete1. 代码示例 (kotlin)12345678910111213@Testfun testDelete() { // 创建连接 val connection = ConnectionFactory.createC

2018-06-20

Hbase源码05_Put

[TOC] Hbase源码05_Put1. 代码示例 (kotlin)12345678910111213@Testfun testPut() { // 创建连接 val connection = ConnectionFactory.createConnect

2018-06-15

Hbase源码04_Get

[TOC] Hbase源码04_Get1. 代码示例 (kotlin)1234567891011121314@Testfun testGet() { // 创建连接 val connection = ConnectionFactory.createConne

2018-06-10

Hbase源码03_创建表

[TOC] Hbase源码03_创建表1. 代码示例 (kotlin)123456789101112@Testfun testCreateTable() { // 创建连接 val connection = ConnectionFactory.createC