一文流：hive使用 bulk load 批量导入数据到 hbase

浅浅的花香味﹌ 2022-12-22 11:16 509阅读 0赞

本文主要参考了hbase和hive官方文档的说明，并结合cdh和hdp的一些教程以及个人在生产中的实践进行记录。主要内容有hbase bulkload的原理以及对应hive的操作步骤，最后基于cdh进行完整实验提供参考实例。  
不过整个操作确实很复杂繁琐，不是很建议使用。现在有挺多使用Spark Bulkload，下次有机会尝试一下。  
之前是遇到一个需求，源表在hbase上，需要重新生成rowkey并提取部分字段形成新表。功能很简单，就是行对行映射过去，但是效率太低耗时太长，用bulkload确实解决了当时的麻烦。  
写这篇文章是对自己操作的复盘，同时也梳理一下知识。

实验环境为：CDH6.3.2，对应的各个组件版本为：hadoop3.0.0，hbase2.1.0，hive2.1.1

### 文章目录 ###

*   *  一 hbase bulk loading批量加载 原理
     *   *  1 概述
         *  2 批量加载架构
         *   *  1. 通过MapReduce作业准备数据
             *  2. 完成数据加载
     *  二 hive 操作步骤
     *   *  1. 确定目标hbase表的结构
         *  2. 添加必要的jar包
         *  3. 确定分区范围
         *   *  1. 创建分区信息表
             *  2. 插入分区边界
             *  3. 得到分区文件
         *  4. 生成中间hive表
         *   *  1. 准备中间表存储位置
             *  2. 创建中间表
             *  3. 导入数据
         *  5. 完成bulk load
     *  三 实验
     *   *  0 测试环境及数据源准备
         *   *  1. 环境
             *  2. 权限相关
             *  3. 实验用例
         *  1 创建源表
         *  2 创建rowkey视图
         *  3 创建分区信息表
         *  4 获取分区信息
         *  5 创建hfile表并插入数据
         *   *  1 创建hfile表
             *  2 插入数据
         *  6 完成bulk load
         *   *  1. 创建目标hbase表
             *  2. bulkload
         *  7 总结
     *  四 参考文章

## 一 hbase bulk loading批量加载 原理 ##

这里推荐阅读hbase 最新官方文档：http://hbase.apache.org/2.3/book.html\#arch.bulk.load  
注意官方文档提供了2.2版本和2.3版本，这里原理讲解使用的是最新的，具体操作需结合根据实际使用版本来，有一些细节可能存在差异，例如2.2和2.3版本最终bulkload使用的jar包名称不一样。  
这里简单地机翻一下：

### 1 概述 ###

HBase包括几种将数据加载到表中的方法。 最直接的方法是使用MapReduce任务中的TableOutputFormat类，或使用常规客户端API。 但是，这些方法并不总是最有效的方法。  
批量加载功能使用MapReduce任务以HBase的内部数据格式输出表数据，然后将生成的StoreFiles直接加载到正在运行的集群中。 与通过HBase API进行加载相比，使用批量加载将占用更少的CPU和网络资源。

### 2 批量加载架构 ###

HBase批量加载过程包括两个主要步骤。

#### 1. 通过MapReduce作业准备数据 ####

批量加载的第一步是使用HFileOutputFormat2从MapReduce任务生成HBase数据文件(存储文件)。这种输出格式以HBase的内部存储格式写出数据，以便稍后可以有效地将它们加载到集群中。  
为了有效地运行，必须配置HFileOutputFormat2，使每个输出的HFile都适用于单个region。为此，那些 输出结果将被批量加载到HBase中 的MapReduce任务，使用 Hadoop 的 TotalOrderPartitioner 类将map输出划分为 key 空间的不相交范围，该范围与表中 region 的 key 范围相对应。

HFileOutputFormat2包括一个便捷函数configureIncrementalLoad()，该函数根据表的当前区域边界自动设置TotalOrderPartitioner。

#### 2. 完成数据加载 ####

在准备好要导入的数据之后，通过使用具有 “importtsv.bulk.output” 选项的 importtsv 工具，或通过使用 HFileOutputFormat 的 MapReduce 作业，可以使用 completebulkload 工具将数据导入到正在运行的集群中。 此命令行工具遍历准备好的数据文件，并为每个文件确定文件所属的region。 然后，它将连接上 HFile 对应的合适的 RegionServer ，将其移入其存储目录并将数据提供给客户端。

如果region边界在批量加载准备过程中或在准备和完成步骤之间发生了更改，则completebulkload程序将自动将数据文件分割为与新边界对应的部分。这个过程效率不高，所以用户应该尽量减少准备批量加载和将其导入集群之间的延迟，特别是当其他客户机通过其他方式同时加载数据时。

hadoop jar hbase-mapreduce-VERSION.jar completebulkload [-c /path/to/hbase/config/hbase-site.xml] /user/todd/myoutput mytable

如果类路径中没有提供相应的hbase参数，那么-c config-file选项可以用来指定包含相应hbase参数的文件(例如hbase-site.xml)(另外，如果zookeeper不是由hbase管理的，那么类路径必须包含包含zookeeper配置文件的目录)。

## 二 hive 操作步骤 ##

这里主要参考hive的文档：https://cwiki.apache.org/confluence/display/Hive/HBaseBulkLoad

### 1. 确定目标hbase表的结构 ###

这里需要明确最终导入的hbase表的几个限制条件：

1.  目标表必须是新建的（即不能导入到已经存在的表）
2.  目标表只能有一个列族
3.  目标表不能是稀疏的（即每一行数据的结构必须一致）

### 2. 添加必要的jar包 ###

> 实测这一步可跳过，不如自己在hive shell上 add jar 。个人感觉hive.aux.jars.path 这个配置比较鸡肋。又不支持直接指定文件夹，发现少了jar包后还得再去编辑文件，需要的jar包一多xml看起来就很恶心。

1.  将hive操作所需的jar包上传到hdfs

hadoop dfs -put /usr/lib/hive/lib/hbase-VERSION.jar /user/hive/hbase-VERSION.jar
    hadoop dfs -put /usr/lib/hive/lib/hive-hbase-handler-VERSION.jar /user/hive/hive-hbase-handler-VERSION.jar

1.  将其路径添加进 hive-site.xml

<property>
      <name>hive.aux.jars.path</name>
      <value>/user/hive/hbase-VERSION.jar,/user/hive/hive-hbase-handler-VERSION.jar</value>
    </property>

### 3. 确定分区范围 ###

为了最后bulk load的时候可以使用多个reducer加载到多个region，我们需要根据rowkey预先划分好数据的分区范围。这个范围将以文件的形式提供给下一步的中间hive表。这一步的目的就是要得到这个分区文件。

#### 1. 创建分区信息表 ####

分区文件以 org.apache.hadoop.hive.ql.io.HiveNullValueSequenceFileOutputFormat outputformat格式存在于hdfs上。我们可以创建一个分区信息表，指定好该表的存储位置，这样该位置上的文件即为我们要的分区信息文件。  
分区信息表的创建如下：

create external table hb_range_keys(transaction_id_range_start string)
    row format serde
    'org.apache.hadoop.hive.serde2.binarysortable.BinarySortableSerDe'
    stored as
    inputformat
    'org.apache.hadoop.mapred.TextInputFormat'
    outputformat
    'org.apache.hadoop.hive.ql.io.HiveNullValueSequenceFileOutputFormat'
    location '/tmp/hb_range_keys';

#### 2. 插入分区边界 ####

这一步需要插入rowkey的边界。例如，插入数据为 005，则最终生成的hbase的region有两个：下边界005、005上边界。  
边界的选择很重要，良好的预分区设计可以减少hbase再平衡的压力，在大数据量下很有用。  
因为我们的源表已经存在于hive中了，而目标hbase表的rowkey又是符合字典排序的。所以我们完全可以利用hive的抽样功能先生成hbase的rowkey序列并排好序，再以一定的间隔进行取样，这样就可以得到分布比较合理的边界值了。  
抽样的实现参考如下：

-- 添加必要的 jar 包 
    
    add jar lib/hive-contrib-0.7.0.jar;
    
    --设置reduce任务数为1
    
    set mapred.reduce.tasks=1;
    
    --创建临时函数 row_sequence，用于让结果带上排序编号
    
    create temporary function row_sequence as
    'org.apache.hadoop.hive.contrib.udf.UDFRowSequence';
    
    --插入抽样结果到 分区信息表
    
    insert overwrite table hb_range_keys -- 步骤（3）
        select transaction_id from   -- 步骤（2）
            (select transaction_id     -- 步骤（1）
                from transactions
            tablesample(bucket 1 out of 10000 on transaction_id) s
            order by transaction_id
            limit 10000000
            ) x
        where (row_sequence() % 910000)=0
        order by transaction_id
        limit 11;
        
    -- region数量=count(1)+1
     
    select count(1) from hb_range_keys ;

这里 transactions 是源表，transaction\_id 是导入到 hbase 中的 rowkey （实际使用可能需要生成，这里暂用 transaction\_id 字段代替）  
步骤（1）：根据transaction\_id字段将数据分到 1万 个桶里，取里面的第一个桶。理论上约等于按 万分之一 进行抽样，抽样后的结果限制最多为 1千万 条。  
步骤（2）：对步骤（1）的结果按照 rowkey 排序，每 91万 条 取 一条 作为最终结果，最多有 11 条（1000/91<=11）。  
步骤（3）：将步骤（2）的结果插入到分区信息表

综上，假设源表的数据量在1千亿以上，经过两次抽样后最终最多被划分成了12个region。

> 注意：桶抽样得到的数量不可靠，在极端情况下步骤（1）抽样的结果可能较少，所以需要自己确定分区信息表的记录行数，后面会用到。

#### 3. 得到分区文件 ####

在hive shell下执行改命令，即可得到分区文件 /tmp/hb\_range\_key\_list

dfs -cp /tmp/hb_range_keys/* /tmp/hb_range_key_list;

### 4. 生成中间hive表 ###

该表用于生成符合 bulk load 格式要求的hfile文件。最终该表的数据都将移动到hbase中。

#### 1. 准备中间表存储位置 ####

因为中间表的占用的空间一般要比hbase的还大（数据是相同的，但hbase一般会压缩得比较好）  
所以中间表的存储位置要特别注意。  
如果存储位置不存在，hive会自动创建。如果存储位置已存在，需确保其内容为空。

dfs -rmr /tmp/hbsort;
    dfs -mkdir /tmp/hbsort;

#### 2. 创建中间表 ####

mapred.reduce.tasks=region数量=分区信息表记录数+1  
total.order.partitioner.path即为分区文件路径  
注意：hfile.family.path=中间表存储路径/列族名

set hive.execution.engine=mr;
    set mapred.reduce.tasks=12;
    set hive.mapred.partitioner=org.apache.hadoop.mapred.lib.TotalOrderPartitioner;
    set total.order.partitioner.path=/tmp/hb_range_key_list;
    set hfile.compression=gz;
     
    create table hbsort(transaction_id string, user_name string, amount double, ...)
    stored as
    INPUTFORMAT 'org.apache.hadoop.mapred.TextInputFormat'
    OUTPUTFORMAT 'org.apache.hadoop.hive.hbase.HiveHFileOutputFormat'
    TBLPROPERTIES ('hfile.family.path' = '/tmp/hbsort/cf');

#### 3. 导入数据 ####

注意这里使用 cluster by 后加 排序字段（rowkey）

insert overwrite table hbsort
    select transaction_id, user_name, amount, ...
    from transactions
    cluster by transaction_id;

### 5. 完成bulk load ###

这一步已经和hive没什么关系了，以上面 bulk load 为准。hive的文档有些过时了：

hadoop jar hbase-VERSION.jar completebulkload [-c /path/to/hbase/config/hbase-site.xml] /tmp/hbsort transactions

## 三 实验 ##

### 0 测试环境及数据源准备 ###

#### 1. 环境 ####

实验环境为：CDH6.3.2 parcel安装版本，对应的各个组件版本为：hadoop3.0.0，hbase2.1.0，hive2.1.1

注意，不同方式安装的组件位置不同，jar包位置也不一样  
parcels 安装的 默认在 /opt/cloudera/parcels/CDH/lib/组件名  
package 安装的 默认在 /usr/lib/组件名  
开源hadoop的就随意了  
下面的以 parcels 为准

#### 2. 权限相关 ####

请自行解决。  
我这里直接把dfs的权限认证给关闭了。生产环境我用的是kerberos，主要需要确保使用的用户对hive、hbase目录有相应的读写权限。

#### 3. 实验用例 ####

参考 hdp的文档： https://docs.cloudera.com/HDPDocuments/HDP1/HDP-1.3.10/bk\_user-guide/content/user-guide-hbase-import-1.html  
我下载的数据是：  
https://dumps.wikimedia.org/other/pagecounts-raw/2008/2008-08/pagecounts-20080801-010000.gz

### 1 创建源表 ###

# 下载测试数据
    wget https://dumps.wikimedia.org/other/pagecounts-raw/2008/2008-08/pagecounts-20080801-010000.gz
    # 解压
    gzip pagecounts-20080801-010000.gz -d 
    # 创建源表存储路径
    hadoop fs -mkdir /tmp/wikistats
    # 上传测试数据
    hadoop fs -put pagecounts-20080801-010000 /tmp/wikistats/

进入 hive shell 创建表  
这里我们创建了 pagecounts 表作为源表

CREATE TABLE IF NOT EXISTS pagecounts (projectcode STRING, pagename STRING, pageviews STRING, bytes STRING)
    ROW FORMAT
      DELIMITED FIELDS TERMINATED BY ' '
      LINES TERMINATED BY '\n'
    STORED AS TEXTFILE
    LOCATION '/tmp/wikistats';

我们可以select一下看一下数据的样子  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FsaW55dWE_size_16_color_FFFFFF_t_70_pic_center]  
最好再count一下看一下数据量大小，这里可以看到是 3039029  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FsaW55dWE_size_16_color_FFFFFF_t_70_pic_center 1]

### 2 创建rowkey视图 ###

创建视图，用于获取自定义的rowkey，以后对源表的操作的转为对此视图的操作  
注意必须保证生成rowkey没有重复，不然在最后一步写hfile的时候会报错：Added a key not lexically larger than previous。hbase的api写rowkey重复倒没什么问题，相当于覆盖，但这里是直接写hfile，必须保证rowkey不重复。  
实测这里给的rowkey生成方法是会导致重复的。

hql如下：

CREATE VIEW IF NOT EXISTS pgc (rowkey, pageviews, bytes) AS
    SELECT concat_ws('/',
             projectcode,
             concat_ws('/',
               pagename,
               regexp_extract(INPUT__FILE__NAME, 'pagecounts-(\\d{8}-\\d{6})\\..*$', 1))),
           pageviews, bytes
    FROM pagecounts;

![在这里插入图片描述][2020112001012265.png_pic_center]  
检测重复：

select rowkey,count(1) from pgc group by rowkey having count(1)>1;

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FsaW55dWE_size_16_color_FFFFFF_t_70_pic_center 2]  
既然如此，我们还是直接创建一个rowkey视图表出来，然后把重复的和源表都删掉吧。

> 注意hive的distinct是无法识别字段级的重复的，而group by也没办法用在这里，所以我用的是 not in。

-- 创建 pgct表 取代 源表pagecounts和视图pgc
    CREATE TABLE IF NOT EXISTS pgct   
    ROW FORMAT
      DELIMITED FIELDS TERMINATED BY ' '
      LINES TERMINATED BY '\n'
    STORED AS TEXTFILE
    LOCATION '/tmp/wikistats_pgct'
     AS
    SELECT *
    FROM pgc where rowkey not in
    ( select rowkey from pgc group by rowkey having count(1)>1)
    ;
    -- 查看内容格式是否正确
    select * from pgct limit 1;
    -- 再次确认是否有重复的rowkey
    select rowkey,count(1) from pgct group by rowkey having count(1)>1;
    -- 删除源表
    drop table pagecounts;
    -- 删除视图
    drop view pgc;

如果视图pgc没有重复的rowkey就不用那么麻烦再生成pgct表了

### 3 创建分区信息表 ###

创建的分区信息表名为：hbase\_splits

> 原教程的列名为 partition ，会导致异常，我这里改为了 key。异常信息为：FAILED: ParseException line 1:49 cannot recognize input near ‘partition’ ‘STRING’ ‘)’ in column name or primary key or foreign key

> hbase\_splits\_tmp的作用：  
> 用于获取分区信息的行数  
> 其他的教程都没有写到需要count获取分区信息表的行数，但如果没获取就没办法正确设置下一步的mapred.reduce.tasks。  
> hbase\_splits表由于存储格式和inputformat的关系，存在一些bug，没办法select出内容，甚至连count都不行。所以我这里用了hbase\_splits\_tmp进行记录，内容先写到hbase\_splits\_tmp，count完再把hbase\_splits\_tmp的内容写到hbase\_splits上。

CREATE EXTERNAL TABLE IF NOT EXISTS hbase_splits(key STRING) 
    ROW FORMAT
      SERDE 'org.apache.hadoop.hive.serde2.binarysortable.BinarySortableSerDe'
    STORED AS
     INPUTFORMAT 'org.apache.hadoop.mapred.TextInputFormat'
     OUTPUTFORMAT 'org.apache.hadoop.hive.ql.io.HiveNullValueSequenceFileOutputFormat'
    LOCATION '/tmp/hbase_splits_out';
    
    CREATE TABLE IF NOT EXISTS hbase_splits_tmp(key STRING) 
    ROW FORMAT
      DELIMITED FIELDS TERMINATED BY ' '
      LINES TERMINATED BY '\n'
    STORED AS TEXTFILE
    LOCATION '/tmp/hbase_splits_tmp';

### 4 获取分区信息 ###

我们源表的数据在300万条以上（教程里的数据是在400w条左右，这里为了偷懒，就不改了）  
这里设计为每1w条抽出一条，得到400条以内的结果，再每100条取1，最终不超过4条rowkey作为边界。

这里为了使用 row\_seq 需要添加 hive-contrib 包

这里是对视图进行操作，视图里已经规定了rowkey的设计方法了  
最后，要根据存储位置把文件cp成一个文件

ADD JAR /opt/cloudera/parcels/CDH/lib/hive/contrib/hive-contrib-2.1.1-cdh6.3.2.jar;
    SET mapred.reduce.tasks=1;
    
    CREATE TEMPORARY FUNCTION row_seq AS 'org.apache.hadoop.hive.contrib.udf.UDFRowSequence';
    
    -- 获取分区信息
    INSERT OVERWRITE TABLE hbase_splits_tmp
    SELECT rowkey FROM
      (SELECT rowkey, row_seq() AS seq FROM pgct
       TABLESAMPLE(BUCKET 1 OUT OF 10000 ON rowkey) s
       ORDER BY rowkey
       LIMIT 400) x
    WHERE (seq % 100) = 0
    ORDER BY rowkey
    LIMIT 4;
    
    -- 查看内容 及 获取count数
    select * from hbase_splits_tmp;
    select count(1) from hbase_splits_tmp;
    
    -- 内容写到hbase_splits_tmp
    INSERT OVERWRITE TABLE hbase_splits_tmp
    SELECT * FROM hbase_splits_tmp;
    
    -- 删除临时工具表
    drop table hbase_splits_tmp;
    
    -- 得到分区信息文件
    dfs -cp /tmp/hbase_splits_out/* /tmp/hbase_splits;

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FsaW55dWE_size_16_color_FFFFFF_t_70_pic_center 3]

### 5 创建hfile表并插入数据 ###

#### 1 创建hfile表 ####

这个表用来生成hfile，这里我们使用的列族为 w

CREATE TABLE hbase_hfiles(rowkey STRING, pageviews STRING, bytes STRING)
    STORED AS
      INPUTFORMAT 'org.apache.hadoop.mapred.TextInputFormat'
      OUTPUTFORMAT 'org.apache.hadoop.hive.hbase.HiveHFileOutputFormat'
    TBLPROPERTIES('hfile.family.path' = '/tmp/hbase_hfiles/w');

#### 2 插入数据 ####

total.order.partitioner.path 用于指定使用的分区排序文件的位置，已经过时，使用 mapreduce.totalorderpartitioner.path 代替。  
注意，我这里把hive 的lib下所有带有hbase的包都添加进去了。理论上应该是完整的了，不过实测还是会提示缺少类：.ClassNotFoundException: org.apache.hadoop.hbase.shaded.protobuf.generated.HFileProtos$FileInfoProto。  
这个类是在hbase-protocol-shaded.jar包里的，需要到hbase目录里才能找到，也给添加进去，就可以了。  
mapred.reduce.tasks数目是前方预估的regions数。

最后一步select出来的数据必须保证无重复的rowkey，实测加distinct 也没用。

ADD JAR /opt/cloudera/parcels/CDH/lib/hive/lib/hbase-client.jar;
    ADD JAR /opt/cloudera/parcels/CDH/lib/hive/lib/hbase-common.jar;
    ADD JAR /opt/cloudera/parcels/CDH/lib/hive/lib/hbase-hadoop2-compat.jar;
    ADD JAR /opt/cloudera/parcels/CDH/lib/hive/lib/hbase-hadoop-compat.jar;
    ADD JAR /opt/cloudera/parcels/CDH/lib/hive/lib/hbase-http.jar;
    ADD JAR /opt/cloudera/parcels/CDH/lib/hive/lib/hbase-mapreduce.jar;
    ADD JAR /opt/cloudera/parcels/CDH/lib/hive/lib/hbase-metrics-api.jar;
    ADD JAR /opt/cloudera/parcels/CDH/lib/hive/lib/hbase-metrics.jar;
    ADD JAR /opt/cloudera/parcels/CDH/lib/hive/lib/hbase-procedure.jar;
    ADD JAR /opt/cloudera/parcels/CDH/lib/hive/lib/hbase-protocol.jar;
    ADD JAR /opt/cloudera/parcels/CDH/lib/hive/lib/hbase-replication.jar;
    ADD JAR /opt/cloudera/parcels/CDH/lib/hive/lib/hbase-server.jar;
    ADD JAR /opt/cloudera/parcels/CDH/lib/hive/lib/hbase-shaded-miscellaneous.jar;
    ADD JAR /opt/cloudera/parcels/CDH/lib/hive/lib/hbase-shaded-netty.jar;
    ADD JAR /opt/cloudera/parcels/CDH/lib/hive/lib/hbase-shaded-protobuf.jar;
    ADD JAR /opt/cloudera/parcels/CDH/lib/hive/lib/hbase-zookeeper.jar;
    ADD JAR /opt/cloudera/parcels/CDH/lib/hive/lib/tephra-hbase-compat-1.0-0.6.0.jar;
    ADD JAR /opt/cloudera/parcels/CDH/lib/hive/lib/hive-hbase-handler.jar;
    
    ADD JAR /opt/cloudera/parcels/CDH/lib/hbase/hbase-protocol-shaded.jar;
    
    SET mapred.reduce.tasks=3;
    SET hive.mapred.partitioner=org.apache.hadoop.mapred.lib.TotalOrderPartitioner;
    SET mapreduce.totalorderpartitioner.path=/tmp/hbase_splits;
    
    -- generate hfiles using the splits ranges
    INSERT OVERWRITE TABLE hbase_hfiles
    SELECT distinct rowkey, pageviews, bytes FROM pgct
    CLUSTER BY rowkey;

### 6 完成bulk load ###

#### 1. 创建目标hbase表 ####

在hbase shell下执行

create 'page_count', {   NAME =>'w',COMPRESSION => 'SNAPPY' }

![在这里插入图片描述][20201123142510273.png_pic_center]

#### 2. bulkload ####

bulkload有两种写法，这里推荐使用下面的第二种，不需要设置classpath，如果是使用 hadoop jar需要将 hbase classpath 添加到 hadoop classpath

# hadoop jar hbase-mapreduce.jar completebulkload /tmp/hbase_hfiles page_count
    hbase org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles /tmp/hbase_hfiles page_count

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FsaW55dWE_size_16_color_FFFFFF_t_70_pic_center 4]

### 7 总结 ###

不同的版本会有不同的问题。我自己使用的官方开源版本的hive获取分区信息的时候可以直接count，这里用的比较老，似乎就有问题。  
另外需要注意可能会各种缺少class，所以建议直接add所有hbase相关的包。

## 四 参考文章 ##

*  hbase官方教程：  
    http://hbase.apache.org/2.2/book.html\#arch.bulk.load
 *  hive 官方教程：  
    https://cwiki.apache.org/confluence/display/Hive/HBaseBulkLoad
 *  hortonworks教程：  
    https://docs.cloudera.com/HDPDocuments/HDP1/HDP-1.3.10/bk\_user-guide/content/user-guide-hbase-import-1.html
 *  有赞HBase Bulkload 实践探讨：https://tech.youzan.com/hbase-bulkloadshi-practice/

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FsaW55dWE_size_16_color_FFFFFF_t_70_pic_center]: /images/20221120/d3e2be23c6494bc486514049f38073e7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FsaW55dWE_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20221120/5c015bd1d8854e63a909d54c89bd8190.png
[2020112001012265.png_pic_center]: /images/20221120/7e5b9f5a51f34193b7c4490a49548c4d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FsaW55dWE_size_16_color_FFFFFF_t_70_pic_center 2]: /images/20221120/2d0f650a8a5e4911ac09ff4c9f3f9910.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FsaW55dWE_size_16_color_FFFFFF_t_70_pic_center 3]: /images/20221120/2eb6fce01df1407b83e1ee8300a649e9.png
[20201123142510273.png_pic_center]: /images/20221120/967578569f464b1fb1214e3aa10bd4da.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FsaW55dWE_size_16_color_FFFFFF_t_70_pic_center 4]: /images/20221120/6ce6c52e86ea4305bde6b6709bc10353.png