Module org.apache.arrow.vector

Package 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	Description
static enum	CompressionUtil.CodecType	Compression codec types corresponding to flat buffer implementation in CompressionType.

Field Summary

Fields

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

Method Summary

Modifier and Type	Method	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 Details

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 Details

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.