Package org.elasticsearch.xpack.esql.datasource.http

Class HttpStorageProvider

java.lang.Object

org.elasticsearch.xpack.esql.datasource.http.HttpStorageProvider

All Implemented Interfaces:

Closeable, AutoCloseable, StorageProvider

public final class HttpStorageProvider
extends Object
implements StorageProvider

StorageProvider implementation for HTTP/HTTPS using Java's built-in HttpClient. Features: - Full object reads via GET - Range reads via HTTP Range header - Metadata retrieval via HEAD - Configurable timeouts and redirects Note: HTTP/HTTPS does not support directory listing, so listObjects() returns null.

Constructor Summary

Constructors

Constructor	Description
HttpStorageProvider(HttpConfiguration config, ExecutorService executor)	Creates an HttpStorageProvider with configuration and executor.

Method Summary

Modifier and Type	Method	Description
void	close()
HttpConfiguration	config()
boolean	exists(StoragePath path)
HttpClient	httpClient()
StorageIterator	listObjects(StoragePath prefix, boolean recursive)
StorageObject	newObject(StoragePath path)
StorageObject	newObject(StoragePath path, long length)
StorageObject	newObject(StoragePath path, long length, Instant lastModified)
List<String>	supportedSchemes()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

HttpStorageProvider

public HttpStorageProvider(HttpConfiguration config,
 ExecutorService executor)

Creates an HttpStorageProvider with configuration and executor.

Parameters:

config - the HTTP configuration

executor - the executor service for async operations

Method Details

newObject

public StorageObject newObject(StoragePath path)

Specified by:

newObject in interface StorageProvider

newObject

public StorageObject newObject(StoragePath path,
 long length)

Specified by:

newObject in interface StorageProvider

newObject

public StorageObject newObject(StoragePath path,
 long length,
 Instant lastModified)

Specified by:

newObject in interface StorageProvider

listObjects

public StorageIterator listObjects(StoragePath prefix,
 boolean recursive)
                            throws IOException

Specified by:

listObjects in interface StorageProvider

Throws:

IOException

exists

public boolean exists(StoragePath path)
               throws IOException

Specified by:

exists in interface StorageProvider

Throws:

IOException

supportedSchemes

public List<String> supportedSchemes()

Specified by:

supportedSchemes in interface StorageProvider

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

httpClient

public HttpClient httpClient()

config

public HttpConfiguration config()

toString

public String toString()

Overrides:

toString in class Object