Package org.elasticsearch.xpack.esql.datasources

Class DecompressionCodecRegistry

java.lang.Object

org.elasticsearch.xpack.esql.datasources.DecompressionCodecRegistry

public class DecompressionCodecRegistry
extends Object

Registry for DecompressionCodec implementations, keyed by extension. Populated from DataSourcePlugin.decompressionCodecs(Settings) at startup.

Constructor Summary

Constructors

Constructor	Description
DecompressionCodecRegistry()

Method Summary

Modifier and Type	Method	Description
DecompressionCodec	byExtension(String extension)	Look up a codec by extension (e.g.
boolean	hasCompressionExtension(String extension)	Returns true if the given extension is a known compression extension.
void	register(DecompressionCodec codec)	Register a codec and its extensions.
String	stripCompressionSuffix(String objectName)	If the object name ends with a known compression extension, strips it and returns the inner name (e.g.

Methods inherited from class java.lang.Object

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

Constructor Details

DecompressionCodecRegistry

public DecompressionCodecRegistry()

Method Details

register

public void register(DecompressionCodec codec)

Register a codec and its extensions.

byExtension

public DecompressionCodec byExtension(String extension)

Look up a codec by extension (e.g. ".gz").

hasCompressionExtension

public boolean hasCompressionExtension(String extension)

Returns true if the given extension is a known compression extension.

stripCompressionSuffix

public String stripCompressionSuffix(String objectName)

If the object name ends with a known compression extension, strips it and returns the inner name (e.g. "data.csv.gz" -> "data.csv"). Otherwise returns null.