Package ai.rapids.cudf.nvcomp

Class BatchedLZ4Decompressor

java.lang.Object

ai.rapids.cudf.nvcomp.BatchedDecompressor

ai.rapids.cudf.nvcomp.BatchedLZ4Decompressor

public class BatchedLZ4Decompressor
extends BatchedDecompressor

LZ4 decompressor that operates on multiple input buffers in a batch

Constructor Summary

Constructors

Constructor	Description
BatchedLZ4Decompressor(long chunkSize)

Method Summary

Modifier and Type	Method	Description
protected void	batchedDecompressAsync(long devInPtrs, long devInSizes, long devOutSizes, long batchSize, long tempPtr, long tempSize, long devOutPtrs, long stream)	Asynchronously decompress a batch of compressed data buffers.
protected long	batchedDecompressGetTempSize(long numChunks, long maxUncompressedChunkBytes)	Computes the temporary storage size in bytes needed to decompress a compressed batch.
static void	decompressAsync(long chunkSize, BaseDeviceMemoryBuffer[] origInputs, BaseDeviceMemoryBuffer[] outputs, Cuda.Stream stream)	Asynchronously decompress a batch of buffers

Methods inherited from class ai.rapids.cudf.nvcomp.BatchedDecompressor

decompressAsync

Methods inherited from class java.lang.Object

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

Constructor Details

BatchedLZ4Decompressor

public BatchedLZ4Decompressor(long chunkSize)

Method Details

decompressAsync

public static void decompressAsync(long chunkSize,
 BaseDeviceMemoryBuffer[] origInputs,
 BaseDeviceMemoryBuffer[] outputs,
 Cuda.Stream stream)

Asynchronously decompress a batch of buffers

Parameters:

chunkSize - maximum uncompressed block size, must match value used during compression

origInputs - buffers to decompress, will be closed by this operation

outputs - output buffers that will contain the compressed results, each must be sized to the exact decompressed size of the corresponding input

stream - CUDA stream to use Deprecated: Use the non-static version in the parent class instead.

batchedDecompressGetTempSize

protected long batchedDecompressGetTempSize(long numChunks,
 long maxUncompressedChunkBytes)

Description copied from class: BatchedDecompressor

Computes the temporary storage size in bytes needed to decompress a compressed batch.

Specified by:

batchedDecompressGetTempSize in class BatchedDecompressor

Parameters:

numChunks - number of chunks in the batch

maxUncompressedChunkBytes - maximum uncompressed size of any chunk in bytes

Returns:

number of temporary storage bytes needed to decompress the batch

batchedDecompressAsync

protected void batchedDecompressAsync(long devInPtrs,
 long devInSizes,
 long devOutSizes,
 long batchSize,
 long tempPtr,
 long tempSize,
 long devOutPtrs,
 long stream)

Description copied from class: BatchedDecompressor

Asynchronously decompress a batch of compressed data buffers.

Specified by:

batchedDecompressAsync in class BatchedDecompressor

Parameters:

devInPtrs - device address of compressed input buffer addresses vector

devInSizes - device address of compressed input buffer sizes vector

devOutSizes - device address of uncompressed buffer sizes vector

batchSize - number of buffers in the batch

tempPtr - device address of the temporary decompression space

tempSize - size of the temporary decompression space in bytes

devOutPtrs - device address of uncompressed output buffer addresses vector

stream - CUDA stream to use