Package org.elasticsearch.xpack.esql.datasource.zstd

Class ZstdDecompressionCodec

java.lang.Object

org.elasticsearch.xpack.esql.datasource.zstd.ZstdDecompressionCodec

All Implemented Interfaces:

DecompressionCodec

public class ZstdDecompressionCodec
extends Object
implements DecompressionCodec

Zstd decompression codec for compound extensions like .csv.zst or .ndjson.zstd.

Uses ZstdInputStream from zstd-jni for streaming decompression.

Constructor Summary

Constructors

Constructor	Description
ZstdDecompressionCodec()

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

ZstdDecompressionCodec

public ZstdDecompressionCodec()

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