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

Class S3StorageProvider

java.lang.Object

org.elasticsearch.xpack.esql.datasource.s3.S3StorageProvider

All Implemented Interfaces:

Closeable, AutoCloseable, StorageProvider

public final class S3StorageProvider
extends Object
implements StorageProvider

StorageProvider implementation for S3 using AWS SDK v2.

Constructor Summary

Constructors

Constructor	Description
S3StorageProvider(S3Configuration config)

Method Summary

Modifier and Type	Method	Description
void	close()
S3Configuration	config()
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)
software.amazon.awssdk.services.s3.S3Client	s3Client()
List<String>	supportedSchemes()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

S3StorageProvider

public S3StorageProvider(S3Configuration config)

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

s3Client

public software.amazon.awssdk.services.s3.S3Client s3Client()

config

public S3Configuration config()

toString

public String toString()

Overrides:

toString in class Object