Package org.elasticsearch.xpack.esql.datasources

Class FormatReaderRegistry

java.lang.Object

org.elasticsearch.xpack.esql.datasources.FormatReaderRegistry

public class FormatReaderRegistry
extends Object

Registry for FormatReader implementations, keyed by format name and file extension. Readers are created lazily on first access to avoid pulling in heavy dependencies at startup. Supports compound extensions (e.g. .csv.gz) via DecompressionCodecRegistry.

Constructor Summary

Constructors

Constructor	Description
FormatReaderRegistry(DecompressionCodecRegistry codecRegistry)

Method Summary

Modifier and Type	Method	Description
FormatReader	byExtension(String objectName)
FormatReader	byName(String formatName)
FormatReader	findByName(String formatName)	Look up a format reader by name, returning null if not registered.
boolean	hasCompressedExtension(String objectName)	Returns true if the object name has a compound extension (e.g.
boolean	hasExtension(String extension)
boolean	hasFormat(String formatName)
void	registerExtension(String extension, String formatName)
void	registerLazy(String formatName, FormatReaderFactory factory, Settings settings, BlockFactory blockFactory)
Supplier<FormatReader>	unregister(String formatName)

Methods inherited from class java.lang.Object

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

Constructor Details

FormatReaderRegistry

public FormatReaderRegistry(DecompressionCodecRegistry codecRegistry)

Method Details

registerLazy

public void registerLazy(String formatName,
 FormatReaderFactory factory,
 Settings settings,
 BlockFactory blockFactory)

unregister

public Supplier<FormatReader> unregister(String formatName)

byName

public FormatReader byName(String formatName)

findByName

public FormatReader findByName(String formatName)

Look up a format reader by name, returning null if not registered. Use for speculative lookups where a missing format is normal (e.g., optimizer probing).

registerExtension

public void registerExtension(String extension,
 String formatName)

byExtension

public FormatReader byExtension(String objectName)

hasCompressedExtension

public boolean hasCompressedExtension(String objectName)

Returns true if the object name has a compound extension (e.g. .csv.gz) that is supported: the last extension is a known compression extension and the stripped path has a format.

hasFormat

public boolean hasFormat(String formatName)

hasExtension

public boolean hasExtension(String extension)