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

Class HttpStorageObject

java.lang.Object

org.elasticsearch.xpack.esql.datasource.http.HttpStorageObject

All Implemented Interfaces:

StorageObject

public final class HttpStorageObject
extends Object
implements StorageObject

StorageObject implementation using HTTP Range requests for efficient partial reads. Uses standard Java HttpClient and InputStream - no custom stream classes needed.

Supports:

• Full object reads via GET
• Range reads via HTTP Range header for columnar formats
• Metadata retrieval via HEAD requests

Field Summary

Fields inherited from interface org.elasticsearch.xpack.esql.datasources.spi.StorageObject

TRANSFER_BUFFER_SIZE

Constructor Summary

Constructors

Constructor	Description
HttpStorageObject(HttpClient client, StoragePath path, HttpConfiguration config)	Creates an HttpStorageObject without pre-known metadata.
HttpStorageObject(HttpClient client, StoragePath path, HttpConfiguration config, long length)	Creates an HttpStorageObject with pre-known length.
HttpStorageObject(HttpClient client, StoragePath path, HttpConfiguration config, long length, Instant lastModified)	Creates an HttpStorageObject with pre-known length and last modified time.

Method Summary

Modifier and Type	Method	Description
boolean	exists()
Instant	lastModified()
long	length()
InputStream	newStream()
InputStream	newStream(long position, long length)
StoragePath	path()
void	readBytesAsync(long position, long length, Executor executor, ActionListener<ByteBuffer> listener)	Async byte read using HttpClient.sendAsync() for native non-blocking I/O.
boolean	supportsNativeAsync()	Returns true - HttpStorageObject has native async support via HttpClient.sendAsync().

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.xpack.esql.datasources.spi.StorageObject

readBytes, readBytesAsync

Constructor Details

HttpStorageObject

public HttpStorageObject(HttpClient client,
 StoragePath path,
 HttpConfiguration config)

Creates an HttpStorageObject without pre-known metadata.

HttpStorageObject

public HttpStorageObject(HttpClient client,
 StoragePath path,
 HttpConfiguration config,
 long length)

Creates an HttpStorageObject with pre-known length.

HttpStorageObject

public HttpStorageObject(HttpClient client,
 StoragePath path,
 HttpConfiguration config,
 long length,
 Instant lastModified)

Creates an HttpStorageObject with pre-known length and last modified time.

Method Details

newStream

public InputStream newStream()
                      throws IOException

Specified by:

newStream in interface StorageObject

Throws:

IOException

newStream

public InputStream newStream(long position,
 long length)
                      throws IOException

Specified by:

newStream in interface StorageObject

Throws:

IOException

length

public long length()
            throws IOException

Specified by:

length in interface StorageObject

Throws:

IOException

lastModified

public Instant lastModified()
                     throws IOException

Specified by:

lastModified in interface StorageObject

Throws:

IOException

exists

public boolean exists()
               throws IOException

Specified by:

exists in interface StorageObject

Throws:

IOException

path

public StoragePath path()

Specified by:

path in interface StorageObject

readBytesAsync

public void readBytesAsync(long position,
 long length,
 Executor executor,
 ActionListener<ByteBuffer> listener)

Async byte read using HttpClient.sendAsync() for native non-blocking I/O.

This implementation uses Java's built-in async HTTP client to avoid blocking threads during I/O. The executor parameter is ignored since HttpClient manages its own thread pool for async operations (configured at client creation time).

Specified by:

readBytesAsync in interface StorageObject

Parameters:

position - the starting byte position

length - the number of bytes to read

executor - executor (unused - HttpClient uses executor configured at creation)

listener - callback for the result or failure

supportsNativeAsync

public boolean supportsNativeAsync()

Returns true - HttpStorageObject has native async support via HttpClient.sendAsync().

Specified by:

supportsNativeAsync in interface StorageObject