HBase的数据压缩功能依赖系统级的压缩库,需根据选择的算法提前安装对应开发包。常见压缩算法的依赖库及安装命令如下(以CentOS为例):
sudo yum install epel-release # 安装EPEL仓库
sudo yum install snappy-devel # 安装Snappy开发库
sudo yum install gzip-devel
sudo yum install lzo-devel
sudo yum install zstd-devel
HBase的压缩配置主要在/etc/hbase/conf/hbase-site.xml文件中完成,需添加或修改以下核心参数:
通过hbase.regionserver.compression.type参数指定默认压缩算法(覆盖所有列族,可通过表级别配置覆盖):
<property>
<name>hbase.regionserver.compression.type</name>
<value>snappy</value> <!-- 可选值:snappy/gzip/lzo/zstd/none -->
</property>
若需针对特定列族设置压缩算法,可在创建表或修改表结构时通过hbase.columnfamily.compression参数指定:
<property>
<name>hbase.columnfamily.compression</name>
<value>zstd</value> <!-- 示例:列族使用Zstd压缩 -->
</property>
部分算法需指定对应的编解码器类,确保HBase能正确调用压缩库:
<!-- Snappy编解码器 -->
<property>
<name>hbase.io.compress.snappy.codec</name>
<value>org.apache.hadoop.io.compress.SnappyCodec</value>
</property>
<!-- Zstd编解码器(HBase 2.0+支持) -->
<property>
<name>hbase.io.compress.zstd.codec</name>
<value>org.apache.hadoop.io.compress.ZStandardCodec</value>
</property>
<!-- GZIP编解码器 -->
<property>
<name>hbase.io.compress.gzip.codec</name>
<value>org.apache.hadoop.io.compress.GzipCodec</value>
</property>
<property>
<name>hbase.regionserver.compression.threshold</name>
<value>10485760</value> <!-- 10MB -->
</property>
<property>
<name>hbase.regionserver.compression.blocksize</name>
<value>65536</value> <!-- 64KB -->
</property>
修改配置文件后,需重启HBase的Master和RegionServer进程:
sudo systemctl restart hbase-master # 重启HBase Master
sudo systemctl restart hbase-regionserver # 重启所有RegionServer
进入HBase Shell,执行describe命令查看表的压缩设置:
hbase shell
describe 'your_table_name'
输出中应包含类似以下内容(以Snappy为例):
COMPRESSION => 'SNAPPY'
通过Java代码获取表的压缩算法信息:
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.TableName;
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.TableDescriptor;
public class HBaseCompressionCheck {
public static void main(String[] args) throws Exception {
Configuration config = HBaseConfiguration.create();
config.set("hbase.zookeeper.quorum", "your_zookeeper_quorum");
config.set("hbase.zookeeper.property.clientPort", "2181");
try (Connection connection = ConnectionFactory.createConnection(config);
Admin admin = connection.getAdmin()) {
TableDescriptor tableDescriptor = admin.getDescriptor(TableName.valueOf("your_table_name"));
String compressionAlgorithm = tableDescriptor.getColumnFamilies().get(0).getCompressionType().toString();
System.out.println("Compression Algorithm: " + compressionAlgorithm);
}
}
}
编译并运行代码,输出应显示配置的压缩算法(如SNAPPY)。
ClassNotFoundException(如SnappyCodec未找到),需检查对应压缩库是否安装,或确认hbase.io.compress.xxx.codec参数配置正确。