Package org.elasticsearch.xpack.esql.datasource.s3

Class S3StorageObject

java.lang.Object

org.elasticsearch.xpack.esql.datasource.s3.S3StorageObject

All Implemented Interfaces:

StorageObject

public final class S3StorageObject
extends Object
implements StorageObject

StorageObject implementation for S3 using AWS SDK v2. Supports full and range reads, metadata retrieval, and optional native async via S3AsyncClient.

Field Summary

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

TRANSFER_BUFFER_SIZE

Constructor Summary

Constructors

Constructor	Description
S3StorageObject(software.amazon.awssdk.services.s3.S3Client s3Client, String bucket, String key, StoragePath path)
S3StorageObject(software.amazon.awssdk.services.s3.S3Client s3Client, String bucket, String key, StoragePath path, long length)
S3StorageObject(software.amazon.awssdk.services.s3.S3Client s3Client, String bucket, String key, StoragePath path, long length, Instant lastModified)
S3StorageObject(software.amazon.awssdk.services.s3.S3Client s3Client, software.amazon.awssdk.services.s3.S3AsyncClient s3AsyncClient, String bucket, String key, StoragePath path)
S3StorageObject(software.amazon.awssdk.services.s3.S3Client s3Client, software.amazon.awssdk.services.s3.S3AsyncClient s3AsyncClient, String bucket, String key, StoragePath path, long length)
S3StorageObject(software.amazon.awssdk.services.s3.S3Client s3Client, software.amazon.awssdk.services.s3.S3AsyncClient s3AsyncClient, String bucket, String key, StoragePath path, long length, Instant lastModified)

Method Summary

Modifier and Type	Method	Description
String	bucket()
boolean	exists()
String	key()
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)
boolean	supportsNativeAsync()
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

Constructor Details

S3StorageObject

public S3StorageObject(software.amazon.awssdk.services.s3.S3Client s3Client,
 String bucket,
 String key,
 StoragePath path)

S3StorageObject

public S3StorageObject(software.amazon.awssdk.services.s3.S3Client s3Client,
 software.amazon.awssdk.services.s3.S3AsyncClient s3AsyncClient,
 String bucket,
 String key,
 StoragePath path)

S3StorageObject

public S3StorageObject(software.amazon.awssdk.services.s3.S3Client s3Client,
 String bucket,
 String key,
 StoragePath path,
 long length)

S3StorageObject

public S3StorageObject(software.amazon.awssdk.services.s3.S3Client s3Client,
 software.amazon.awssdk.services.s3.S3AsyncClient s3AsyncClient,
 String bucket,
 String key,
 StoragePath path,
 long length)

S3StorageObject

public S3StorageObject(software.amazon.awssdk.services.s3.S3Client s3Client,
 String bucket,
 String key,
 StoragePath path,
 long length,
 Instant lastModified)

S3StorageObject

public S3StorageObject(software.amazon.awssdk.services.s3.S3Client s3Client,
 software.amazon.awssdk.services.s3.S3AsyncClient s3AsyncClient,
 String bucket,
 String key,
 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

bucket

public String bucket()

key

public String key()

readBytesAsync

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

Specified by:

readBytesAsync in interface StorageObject

supportsNativeAsync

public boolean supportsNativeAsync()

Specified by:

supportsNativeAsync in interface StorageObject

toString

public String toString()

Overrides:

toString in class Object