Package org.elasticsearch.xpack.esql.datasource.azure

Class AzureStorageObject

java.lang.Object

org.elasticsearch.xpack.esql.datasource.azure.AzureStorageObject

All Implemented Interfaces:

StorageObject

public final class AzureStorageObject
extends Object
implements StorageObject

StorageObject implementation for Azure Blob Storage. Supports full and range reads, and metadata retrieval with caching.

Field Summary

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

TRANSFER_BUFFER_SIZE

Constructor Summary

Constructors

Constructor	Description
AzureStorageObject(com.azure.storage.blob.BlobClient blobClient, String container, String blobName, StoragePath path)
AzureStorageObject(com.azure.storage.blob.BlobClient blobClient, String container, String blobName, StoragePath path, long length)
AzureStorageObject(com.azure.storage.blob.BlobClient blobClient, String container, String blobName, StoragePath path, 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()
String	toString()

Methods inherited from class java.lang.Object

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

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

readBytes, readBytesAsync, readBytesAsync, supportsNativeAsync

Constructor Details

AzureStorageObject

public AzureStorageObject(com.azure.storage.blob.BlobClient blobClient,
 String container,
 String blobName,
 StoragePath path)

AzureStorageObject

public AzureStorageObject(com.azure.storage.blob.BlobClient blobClient,
 String container,
 String blobName,
 StoragePath path,
 long length)

AzureStorageObject

public AzureStorageObject(com.azure.storage.blob.BlobClient blobClient,
 String container,
 String blobName,
 StoragePath path,
 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

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

toString

public String toString()

Overrides:

toString in class Object