edu.sysu.pmglab.compressor

类 IDecompressor

java.lang.Object

edu.sysu.pmglab.compressor.IDecompressor

所有已实现的接口:

java.lang.AutoCloseable

直接已知子类:

GzipDecompressor, LZ4Decompressor, LzmaDecompressor, ZstdDecompressor

public abstract class IDecompressor
extends java.lang.Object
implements java.lang.AutoCloseable

字段概要

字段

限定符和类型	字段和说明
static java.lang.Class<IDecompressor>[]	COMPRESSOR_ENABLE 请在此处注册方法 (追加元素), 并确保其顺序与 ICompressor 中一致

构造器概要

构造器

构造器和说明
IDecompressor() 构造器方法
IDecompressor(int cacheSize) 构造器方法
IDecompressor(edu.sysu.pmglab.container.VolumeByteStream cache) 构造器方法

方法概要

限定符和类型	方法和说明
abstract void	close() 关闭压缩器方法
abstract int	decompress(byte[] src, int srcOffset, int srcLength, byte[] dst, int dstOffset, int dstLength) 解压缩方法, 解压 src 数据, 并写入到 dst 中
int	decompress(byte[] src, int offset, int length, edu.sysu.pmglab.container.VolumeByteStream dst) 解压缩方法, 压缩 src 数据, 并将压缩结果写入缓冲区或源数据容器
static edu.sysu.pmglab.container.VolumeByteStream	decompress(int compressorIndex, byte[] src, int srcOffset, int srcLength) 一次性解压缩数据
static edu.sysu.pmglab.container.VolumeByteStream	decompress(int compressorIndex, edu.sysu.pmglab.container.VolumeByteStream src) 一次性解压缩数据
int	decompress(edu.sysu.pmglab.container.VolumeByteStream src) 解压缩方法
int	decompress(edu.sysu.pmglab.container.VolumeByteStream src, edu.sysu.pmglab.container.VolumeByteStream dst) 解压缩方法
edu.sysu.pmglab.container.VolumeByteStream	getCache() 直接获取缓冲区
static int	getCompressorIndex(java.lang.String compressorName) 获取解压器索引
static java.lang.String	getCompressorName(int compressorIndex) 获取解压器名字
abstract int	getDecompressBound(byte[] src, int offset, int length) 预估解压大小
static IDecompressor	getInstance(int compressorIndex) 获取解压器实例
static IDecompressor	getInstance(int compressorIndex, int cacheSize) 获取解压器实例
static IDecompressor	getInstance(int compressorIndex, edu.sysu.pmglab.container.VolumeByteStream cache) 获取解压器实例
void	reset() 重设缓冲区

从类继承的方法 java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

COMPRESSOR_ENABLE

public static final java.lang.Class<IDecompressor>[] COMPRESSOR_ENABLE

请在此处注册方法 (追加元素), 并确保其顺序与 ICompressor 中一致

构造器详细资料

IDecompressor

public IDecompressor()

构造器方法

IDecompressor

public IDecompressor(int cacheSize)

构造器方法

参数:

cacheSize - 缓冲区大小

IDecompressor

public IDecompressor(edu.sysu.pmglab.container.VolumeByteStream cache)

构造器方法

参数:

cache - 传入外部缓冲区

方法详细资料

getInstance

public static IDecompressor getInstance(int compressorIndex)

获取解压器实例

参数:

compressorIndex - 解压器索引, 0 代表 zstd, 1 代表 lz4, 2 代表 gzip

返回:

解压器实例

getInstance

public static IDecompressor getInstance(int compressorIndex,
                                        int cacheSize)

获取解压器实例

参数:

compressorIndex - 解压器索引, 0 代表 zstd, 1 代表 lz4, 2 代表 gzip

cacheSize - 缓存数据大小

返回:

解压器实例

getInstance

public static IDecompressor getInstance(int compressorIndex,
                                        edu.sysu.pmglab.container.VolumeByteStream cache)

获取解压器实例

参数:

compressorIndex - 解压器索引, 0 代表 zstd, 1 代表 lzma

cache - 缓存区

返回:

解压器实例

getCompressorIndex

public static int getCompressorIndex(java.lang.String compressorName)

获取解压器索引

参数:

compressorName - 解压器名字

返回:

解压器索引

getCompressorName

public static java.lang.String getCompressorName(int compressorIndex)

获取解压器名字

参数:

compressorIndex - 解压器索引

返回:

解压器名字

decompress

public static edu.sysu.pmglab.container.VolumeByteStream decompress(int compressorIndex,
                                                                    byte[] src,
                                                                    int srcOffset,
                                                                    int srcLength)
                                                             throws java.io.IOException

一次性解压缩数据

参数:

compressorIndex - 解压器索引

src - 待解压缩数据

srcOffset - 源数据偏移量

srcLength - 输入数据长度

返回:

解压结果

抛出:

java.io.IOException - IO 异常

decompress

public static edu.sysu.pmglab.container.VolumeByteStream decompress(int compressorIndex,
                                                                    edu.sysu.pmglab.container.VolumeByteStream src)
                                                             throws java.io.IOException

一次性解压缩数据

参数:

compressorIndex - 解压器索引

src - 待解压缩数据

返回:

解压结果

抛出:

java.io.IOException - IO 异常

getDecompressBound

public abstract int getDecompressBound(byte[] src,
                                       int offset,
                                       int length)

预估解压大小

参数:

src - 源数据

offset - 偏移量

length - 输入数据长度

返回:

预估压缩大小

decompress

public abstract int decompress(byte[] src,
                               int srcOffset,
                               int srcLength,
                               byte[] dst,
                               int dstOffset,
                               int dstLength)
                        throws java.io.IOException

解压缩方法, 解压 src 数据, 并写入到 dst 中

参数:

src - 源数据

srcOffset - 源数据偏移量

srcLength - 源数据传入长度

dst - 目标容器

dstOffset - 目标容器偏移量

dstLength - 目标容器可用长度

返回:

写入数据长度, 通常比 dst 长度小

抛出:

java.io.IOException - IO 异常

close

public abstract void close()

关闭压缩器方法

指定者:

close 在接口中 java.lang.AutoCloseable

getCache

public final edu.sysu.pmglab.container.VolumeByteStream getCache()

直接获取缓冲区

返回:

缓冲区

decompress

public final int decompress(edu.sysu.pmglab.container.VolumeByteStream src)
                     throws java.io.IOException

解压缩方法

参数:

src - 源数据

返回:

写入数据长度

抛出:

java.io.IOException - IO 异常

decompress

public final int decompress(edu.sysu.pmglab.container.VolumeByteStream src,
                            edu.sysu.pmglab.container.VolumeByteStream dst)
                     throws java.io.IOException

解压缩方法

参数:

src - 源数据

dst - 目标容器

返回:

写入数据长度

抛出:

java.io.IOException - IO 异常

decompress

public final int decompress(byte[] src,
                            int offset,
                            int length,
                            edu.sysu.pmglab.container.VolumeByteStream dst)
                     throws java.io.IOException

解压缩方法, 压缩 src 数据, 并将压缩结果写入缓冲区或源数据容器

参数:

src - 字节数组

offset - 偏移量

length - 长度

dst - 目标容器

返回:

写入数据长度

抛出:

java.io.IOException - IO 异常

reset

public final void reset()

重设缓冲区