HBase的压缩功能依赖系统级的压缩库,需根据选择的算法提前安装对应开发包:
sudo yum install epel-release # 启用EPEL仓库
sudo yum install snappy-devel
gzip,无需额外安装。sudo yum install lzo-devel
sudo yum install zstd-devel
注:选择算法时需权衡性能与压缩率,Snappy适合对延迟敏感的场景,GZIP适合存储空间优先的场景。
配置文件路径通常为/etc/hbase/conf/hbase-site.xml,需添加或修改以下关键属性:
<configuration>
<!-- 指定压缩算法(必选) -->
<property>
<name>hbase.regionserver.compression.codec</name>
<value>org.apache.hadoop.hbase.io.compress.SnappyCodec</value> <!-- 替换为目标算法的Codec类 -->
</property>
<!-- 启用压缩(可选,默认false) -->
<property>
<name>hbase.regionserver.compression.type</name>
<value>snappy</value> <!-- 可选值:snappy、gzip、lzo、zstd等 -->
</property>
<!-- 设置压缩阈值(可选,默认0,表示立即压缩) -->
<property>
<name>hbase.regionserver.compression.threshold</name>
<value>10485760</value> <!-- 数据量超过10MB时触发压缩 -->
</property>
<!-- 设置压缩块大小(可选,默认64KB) -->
<property>
<name>hbase.regionserver.compression.blocksize</name>
<value>65536</value> <!-- 64KB,可根据数据特性调整 -->
</property>
</configuration>
<!-- MemStore全局大小阈值(触发flush的阈值,默认0.4) -->
<property>
<name>hbase.regionserver.global.memstore.size</name>
<value>0.4</value> <!-- 占用堆内存的40%时触发flush -->
</property>
<!-- MemStore flush大小(单个Region的MemStore超过该值时flush,默认128MB) -->
<property>
<name>hbase.regionserver.global.memstore.flush.size</name>
<value>134217728</value> <!-- 128MB -->
</property>
注:
hbase.regionserver.compression.codec需与hbase.regionserver.compression.type保持一致,避免配置冲突。
修改配置文件后,需重启HBase集群:
# 停止HBase服务
sudo systemctl stop hbase-regionserver
sudo systemctl stop hbase-master
# 启动HBase服务
sudo systemctl start hbase-master
sudo systemctl start hbase-regionserver
注:建议在低峰期重启,避免影响线上业务。
# 进入HBase Shell
hbase shell
# 查看集群状态中的压缩配置
status 'simple'
# 输出示例(需包含目标压缩算法):
# Compression:
# codec: snappy
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.TableName;
public class HBaseCompressionCheck {
public static void main(String[] args) throws Exception {
// 配置HBase连接
Configuration config = HBaseConfiguration.create();
config.set("hbase.zookeeper.quorum", "your_zookeeper_quorum");
config.set("hbase.zookeeper.property.clientPort", "2181");
// 获取Admin对象
try (Connection connection = ConnectionFactory.createConnection(config);
Admin admin = connection.getAdmin()) {
// 获取目标表的Descriptor
TableName tableName = TableName.valueOf("your_table_name");
var tableDescriptor = admin.getTableDescriptor(tableName);
// 输出压缩算法
System.out.println("Compression Algorithm: " +
tableDescriptor.getCompactionConfiguration().getCompression());
}
}
}
编译并运行代码,若输出为目标压缩算法(如snappy),则说明配置生效。
压缩库未找到:
若启动时报错java.lang.UnsatisfiedLinkError,需检查压缩库路径是否在java.library.path中。可通过修改hbase-env.sh添加:
export HBASE_OPTS="$HBASE_OPTS -Djava.library.path=/usr/lib64"
压缩效果不明显:
若数据本身是文本且重复性低,可尝试更换为Zstd或LZO算法;若数据已压缩(如图片、视频),压缩率会极低,建议关闭压缩。
性能下降:
压缩会增加CPU负载,若CPU使用率过高,可降低压缩级别(部分算法支持)或选择更快的算法(如Snappy)。