Package org.elasticsearch.xpack.esql.datasource.snappy

Class SnappyDecompressionCodec

java.lang.Object

org.elasticsearch.xpack.esql.datasource.snappy.SnappyDecompressionCodec

All Implemented Interfaces:

DecompressionCodec

public class SnappyDecompressionCodec
extends Object
implements DecompressionCodec

Snappy decompression codec for compound extensions like .csv.snappy or .ndjson.snappy.

Uses the standard Snappy framing format (64KB chunks with CRC-32C checksums). CRC-32C verification is enabled by default to detect silent data corruption from remote blob stores. The underlying SnappyFramedInputStream is provided by snappy-java via the esql-datasource-compression-libs parent plugin.

Constructor Summary

Constructors

Constructor	Description
SnappyDecompressionCodec()

Method Summary

Modifier and Type	Method	Description
InputStream	decompress(InputStream raw)
List<String>	extensions()
String	name()

Methods inherited from class java.lang.Object

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

Constructor Details

SnappyDecompressionCodec

public SnappyDecompressionCodec()

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