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

Class LocalStorageObject

java.lang.Object

org.elasticsearch.xpack.esql.datasource.http.local.LocalStorageObject

All Implemented Interfaces:

StorageObject

public final class LocalStorageObject
extends Object
implements StorageObject

StorageObject implementation for local file system. Supports: - Full file reads via FileInputStream - Range reads via RandomAccessFile for columnar formats - File metadata (size, last modified)

Field Summary

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

TRANSFER_BUFFER_SIZE

Constructor Summary

Constructors

Constructor	Description
LocalStorageObject(Path filePath)
LocalStorageObject(Path filePath, long length)
LocalStorageObject(Path filePath, long length, Instant lastModified)

Method Summary

Modifier and Type	Method	Description
boolean	exists()
Instant	lastModified()
long	length()
InputStream	newStream()
InputStream	newStream(long position, long length)
StoragePath	path()
int	readBytes(long position, ByteBuffer target)	Reads directly into the target ByteBuffer using positional FileChannel I/O via Channels.readFromFileChannel(java.nio.channels.FileChannel, long, int).

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

readBytesAsync, readBytesAsync, supportsNativeAsync

Constructor Details

LocalStorageObject

public LocalStorageObject(Path filePath)

LocalStorageObject

public LocalStorageObject(Path filePath,
 long length)

LocalStorageObject

public LocalStorageObject(Path filePath,
 long length,
 Instant lastModified)

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

readBytes

public int readBytes(long position,
 ByteBuffer target)
              throws IOException

Reads directly into the target ByteBuffer using positional FileChannel I/O via Channels.readFromFileChannel(java.nio.channels.FileChannel, long, int). Both heap and direct buffers are handled natively by the OS with no intermediate copies.

Specified by:

readBytes 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