使用压缩

你可以在 YMatrix 中使用通用压缩算法 lz4、zstd、zlib,参数说明如下,在 WITH 语句中实现,如 WITH (compresstype=zstd, compresslevel=3)

1 通用压缩算法

参数名 默认值 最小值 最大值 描述
compress_threshold 1200 1 8000 压缩阈值。用于控制单表多少元组(Tuple)进行一次压缩,是同一个单元中压缩的 Tuple 数上限
compresstype lz4 压缩算法,支持:
1. zstd
2. zlib
3. lz4
compresslevel 1 1 压缩级别。值越小压缩越快,但压缩效果越差;值越大压缩越慢,但压缩效果更好。不同的算法有效值范围都不同:
zstd:1-19
zlib:1-9
lz4:1-20

注意!
一般而言,zstd 符合压缩级别越高,压缩率越高,同时速度越低。但这并不绝对。

2 编码链

除通用压缩算法外,我们更希望你尝试 YMatrix 自研的定制化压缩算法 —— 编码链(mxcustom)。时序数据有很强的特征,例如规律的时间间隔,列间独立,随时间的渐变性等。通用的压缩算法如 lz4 和 zstd 均面向字节流,因没有感知并利用这些特性,蛮力压缩的效果离理想结果差距很大。
编码链则可以充分利用时序数据的特性,对表数据进行深度压缩。深度压缩的好处有如下三方面:

  • 大幅节省存储成本。数据尺寸变小大幅节省了存储成本,使得相同空间、相同机器规模下能容纳更多的数据,存储更多数据资产成为可能。
  • 磁盘 I/O 开销减少。同样是由于数据尺寸的降低,磁盘 I/O 开销减少了,对于涉及大量磁盘 I/O 的查询速度改善明显,特别是在磁盘驱动器(HDD,Hard Disk Drive)上,针对数据偏冷(数据被查询频率低)的场景。
  • 深度优化,加速查询。针对性地压缩算法一方面更简单,且有深度优化的机会,可以做更高速的解压。有机会进一步加速查询。

2.1 介绍

算法 支持参数 描述
lz4 & zstd compresslevel 编码链把 lz4 和 zstd 纳入了编码组合,调用系统提供的压缩库实现压缩和解压缩。lz4 适用于侧重速度,特别解压缩速度的场景。而 zstd 则更均衡。在默认压缩级别下,lz4 的解压速度要明显好于 zstd,而 zstd 的压缩率要明显要于 lz4。一般而言,zstd 压缩级别越高,压缩率越高,而速度越低。但这并不绝对
deltadelta 缩放因子(可选)。缩放因子指的是缩放位数,如 deltadelta(7) 表示对差值做 7 位缩放后再存储。默认不缩放 Delta Delta 原理是将相邻数据做二次差分,特别适合排序后的时间戳。严格保序且无缺失值的时间戳序列的处理结果是全 0 序列,可以做到很好的压缩。有些时间戳如果存在缺失值,则差分后仍有可能是一个很大的数值。deltadelta 只针对整型,且适合二次差分后是小整数的情况
deltazigzag 缩放因子(可选) deltazigzag 的原理是进行一次差分,再使用 zigzag 将可能的负数转成正数,再采用可变长度的整型编码压缩成较小尺寸的小整数。适用于区间较小的整数列,没有排序要求
Gorilla Gorilla 编码用于浮点数的压缩,原理是将数值和前序数值进行异或运算,压缩掉前缀和后缀的零值。目前仅支持 double 类型,即以 8 位为一个数据单元
Floatint 缩放因子(必选) 在一些情况下,Gorilla 对浮点数的压缩并不一定有效。例如,车联网时序场景下,汽车所处位置的经纬度是一个缓慢变化的浮点值,用 Gorilla 压缩率几乎为0。而采用 floatint 搭配 deltadelta 的组合方案,可以达到之前的十几倍。此结果是因为浮点数有专门的内部表示格式,相邻数据的变化相对较小,浮点部分进行异或运算不一定产生较多的零值,但经过一定的缩放得到的整数序列可以很好地保留相似性,反而更容易进行压缩。需要注意的是,floatint 的缩放存在一定的精度损失,引入的误差和缩放因子有关。如果缩放因子是 4,则最大误差是 0.0001
simple8b simple8b 适用于范围较小的整型数,原理是将多个小整数存放到 8 字节的空间中。比如一块数据里都是 < 8 的整数,则每 3 位即可存放一个数,从而起到较好的压缩效果。对此情况,lz4 因数据无规律,压缩效果可能很差

2.2 使用

编码链主要功能见下表:

序号 用法
1 列级别压缩
2 表级别压缩(支持修改算法)
3 既指定表级别,又指定列级别压缩
4 自适应编码(AutoEncode)

下面介绍具体使用方法。无论是哪种用法,都需首先创建拓展。

CREATE EXTENSION matrixts;

2.2.1 列级别压缩

对 t1 每列数据进行定制化压缩指定。encodechain 用来指定编码组合,参数放在括号内,以 "," 隔开,示例如下。

=# CREATE EXTENSION matrixts;
=# CREATE TABLE t1(
  f1 int8 ENCODING(encodechain='deltadelta(7)', compresstype='mxcustom'),
  f2 int8 ENCODING(encodechain='lz4', compresstype='mxcustom')
)
USING MARS2;

创建 mars2_btree 索引。

=# CREATE INDEX t1_index ON t1 
USING mars2_btree(f1);

也可以使用以下 SQL 完成对列级别压缩的指定。

=# CREATE TABLE t1_1(
  f1 int8,COLUMN f1 ENCODING (encodechain='lz4', compresstype='mxcustom'),
  f2 int8,COLUMN f2 ENCODING(encodechain='lz4', compresstype='mxcustom')
)
USING MARS2;
=# CREATE INDEX t1_1_index ON t1_1 
USING mars2_btree(f1);

DEFAULT COLUMN ENCODING 意为默认给所有列指定某一特定压缩算法,相当于表级别压缩。

=# CREATE TABLE t1_2(
  f1 int8,
  f2 int8,
  DEFAULT COLUMN ENCODING (encodechain='auto', compresstype='mxcustom')
)
USING MARS2;
=# CREATE INDEX t1_2_index ON t1_2 
USING mars2_btree(f1);

2.2.2 表级别压缩

假设你想要使用 zstd 压缩算法对表 t2 进行表级别压缩,那么会有两种选择:使用编码链和不使用编码链。此处的区别主要在于,使用编码链进行表级别压缩,可以实现建表后利用 SQL 语句再次修改压缩算法。

如使用编码链基于 zstd 算法对表 t2 进行表级别压缩,示例如下:

=# CREATE TABLE t2 (
      f1 int8
    , f2 int8
) 
USING MARS2
WITH(
      compresstype=mxcustom
    , encodechain=zstd
);
=# CREATE INDEX t2_index ON t2 
USING mars2_btree(f1);

修改表级别压缩算法为自适应编码:

=# ALTER TABLE t2 SET (encodechain=auto);

注意!
encodechain 只适用于 MARS2 表。你可以和过去一样在 MARS2 表中使用原有的压缩方法。例如在 WITH 子句里指定表级压缩。

2.2.3 既指定表级别,又指定列级别压缩

示例中分别对表 t3 及其 列 f1 指定了 autolz4 压缩算法,此时由于列级压缩的指定要优先于表级(列指定 ENCODING(compresstype=none)/ENCODING(minmax) 例外,详见下文),因此最终会对 f1 列进行 lz4 压缩,对 t3 表中的其余列(f2 列)进行自适应编码压缩。

=# CREATE TABLE t3 (
      f1 int8 ENCODING(compresstype=lz4)
    , f2 int8
) 
USING MARS2
WITH(
      compresstype=mxcustom
    , encodechain=auto
);

2.2.4 自适应编码

YMatrix 的编码链支持自适应编码,即运行时系统判断数据特征,并自动选择一套合理的编码方法。

  1. 为 t4 表使用表级别的自适应编码(必须显式指定 encodechain=auto)。

    =# CREATE TABLE t4 (
       f1 int8
     , f2 int8
    ) 
    USING MARS2
    WITH(
       compresstype=mxcustom
     , encodechain=auto
    );
  2. 为 t4 表同时指定表级别的 lz4 与列级别的自适应编码。此种情况下,列 f2 由于未指定特定压缩算法,会使用表级别的算法。

    =# CREATE TABLE t4 (
       f1 int8 ENCODING(encodechain=auto,compresstype=mxcustom)
     , f2 int8 
    ) 
    USING MARS2
    WITH(
       compresstype=mxcustom,
     , encodechain=lz4
    );
  3. 为 t4 表同时指定表级别的 lz4 与列级别的 none 编码链压缩算法。此种情况下,列 f1 不压缩,列 f2 由于未指定特定压缩算法,会使用表级别的算法。

    =# CREATE TABLE t4 (
       f1 int8 ENCODING(encodechain=none,compresstype=mxcustom)
     , f2 int8 
    ) 
    USING MARS2
    WITH(
       compresstype=mxcustom,
     , encodechain=lz4
    );
  4. 为 t4 表同时指定表级别的 lz4 编码链压缩算法与列级别的 none 非编码链压缩算法。此种情况下,列 f1 与列 f2 的非编码链压缩均会被表级别的编码链压缩算法覆盖

    =# CREATE TABLE t4 (
       f1 int8 ENCODING(compresstype=none)
     , f2 int8 ENCODING(minmax)
    ) 
    USING MARS2
    WITH(
       compresstype=mxcustom,
     , encodechain=lz4
    );

在自适应编码功能下,支持在表级别指定自适应编码模式(Automode),选项有压缩率优先和速度优先。示例中为 t4 表开启了压缩率优先模式。automode=1 表示压缩率优先,automode=2 表示速度优先。

## automode=1, auto for cost
## automode=2, auto for speed
CREATE TABLE t4 (
      f1 int8
    , f2 int8
) 
USING MARS2
WITH(
      compresstype=mxcustom
    , automode=1
);