org.apache.arrow.vector.compression

Class CompressionUtil

java.lang.Object

org.apache.arrow.vector.compression.CompressionUtil

public class CompressionUtil
extends Object

Utilities for data compression/decompression.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CompressionUtil.CodecType Compression codec types corresponding to flat buffer implementation in CompressionType.

Field Summary

Fields

Modifier and Type	Field and Description
static long	NO_COMPRESSION_LENGTH Special flag to indicate no compression.
static long	SIZE_OF_UNCOMPRESSED_LENGTH

Method Summary

Modifier and Type	Method and Description
static ArrowBodyCompression	createBodyCompression(CompressionCodec codec) Creates the ArrowBodyCompression object, given the CompressionCodec.
static ArrowBuf	extractUncompressedBuffer(ArrowBuf inputBuffer) Process decompression by slicing the buffer that contains the uncompressed bytes.
static ArrowBuf	packageRawBuffer(BufferAllocator allocator, ArrowBuf inputBuffer) Process compression by compressing the buffer as is.

Methods inherited from class java.lang.Object

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

Field Detail

SIZE_OF_UNCOMPRESSED_LENGTH

public static final long SIZE_OF_UNCOMPRESSED_LENGTH

See Also:

Constant Field Values

NO_COMPRESSION_LENGTH

public static final long NO_COMPRESSION_LENGTH

Special flag to indicate no compression. (e.g. when the compressed buffer has a larger size.)

See Also:

Constant Field Values

Method Detail

createBodyCompression

public static ArrowBodyCompression createBodyCompression(CompressionCodec codec)

Creates the ArrowBodyCompression object, given the CompressionCodec. The implementation of this method should depend on the values of CompressionType.names.

packageRawBuffer

public static ArrowBuf packageRawBuffer(BufferAllocator allocator,
                                        ArrowBuf inputBuffer)

Process compression by compressing the buffer as is.

extractUncompressedBuffer

public static ArrowBuf extractUncompressedBuffer(ArrowBuf inputBuffer)

Process decompression by slicing the buffer that contains the uncompressed bytes.