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

Class AzureStorageProvider

java.lang.Object

org.elasticsearch.xpack.esql.datasource.azure.AzureStorageProvider

All Implemented Interfaces:

Closeable, AutoCloseable, StorageProvider

public final class AzureStorageProvider
extends Object
implements StorageProvider

StorageProvider implementation for Azure Blob Storage.

Supports the wasbs:// and wasb:// URI schemes. URI format: wasbs://account.blob.core.windows.net/container/path/to/blob

• host: account.blob.core.windows.net (account name is first segment)
• path: /container/path/to/blob (first segment = container, remainder = blob name)

Authentication can be provided via connection string, account+key, SAS token, or DefaultAzureCredential when no explicit credentials are configured.

Constructor Summary

Constructors

Constructor	Description
AzureStorageProvider(com.azure.storage.blob.BlobServiceClient blobServiceClient)	Constructor for testing with a pre-built BlobServiceClient.
AzureStorageProvider(AzureConfiguration config)

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	exists(StoragePath path)
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()

Methods inherited from class java.lang.Object

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

Constructor Details

AzureStorageProvider

public AzureStorageProvider(AzureConfiguration config)

AzureStorageProvider

public AzureStorageProvider(com.azure.storage.blob.BlobServiceClient blobServiceClient)

Constructor for testing with a pre-built BlobServiceClient.

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()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException