Package org.elasticsearch.xpack.esql.datasource.bzip2

Class Bzip2DecompressionCodec

java.lang.Object

org.elasticsearch.xpack.esql.datasource.bzip2.Bzip2DecompressionCodec

All Implemented Interfaces:

DecompressionCodec, SplittableDecompressionCodec

public class Bzip2DecompressionCodec
extends Object
implements SplittableDecompressionCodec

Bzip2 decompression codec with splittable support for parallel decompression.

Uses a forked Hadoop-style CBZip2InputStream in BYBLOCK mode for split decompression. The decompressor handles bit-aligned block boundaries natively via skipToNextMarker(), avoiding the need for byte-aligned block offsets.

For split decompression, the stream is positioned at the byte containing the block marker. The CBZip2InputStream in BYBLOCK mode finds the exact bit position, decompresses one block at a time, and reports compressed byte positions at block boundaries. A wrapper monitors these positions and signals EOF when the decompressor passes the split boundary.

Constructor Summary

Constructors

Constructor	Description
Bzip2DecompressionCodec()

Method Summary

Modifier and Type	Method	Description
InputStream	decompress(InputStream raw)
InputStream	decompressRange(StorageObject object, long blockStart, long nextBlockStart)
List<String>	extensions()
long[]	findBlockBoundaries(StorageObject object, long start, long end)
String	name()

Methods inherited from class java.lang.Object

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

Constructor Details

Bzip2DecompressionCodec

public Bzip2DecompressionCodec()

Method Details

name

public String name()

Specified by:

name in interface DecompressionCodec

extensions

public List<String> extensions()

Specified by:

extensions in interface DecompressionCodec

decompress

public InputStream decompress(InputStream raw)
                       throws IOException

Specified by:

decompress in interface DecompressionCodec

Throws:

IOException

findBlockBoundaries

public long[] findBlockBoundaries(StorageObject object,
 long start,
 long end)
                           throws IOException

Specified by:

findBlockBoundaries in interface SplittableDecompressionCodec

Throws:

IOException

decompressRange

public InputStream decompressRange(StorageObject object,
 long blockStart,
 long nextBlockStart)
                            throws IOException

Specified by:

decompressRange in interface SplittableDecompressionCodec

Throws:

IOException