Package io.deephaven.extensions.s3

Class S3FileIOAdapter

java.lang.Object

io.deephaven.iceberg.util.FileIOAdapterBase

io.deephaven.extensions.s3.S3FileIOAdapter

All Implemented Interfaces:

FileIOAdapter

@AutoService(FileIOAdapter.class)
public final class S3FileIOAdapter
extends FileIOAdapterBase

FileIOAdapter implementation used for reading/writing files to S3. This adapter re-uses the S3AsyncClient embedded in an S3FileIO. It is only used when USE_S3_CLIENT_FROM_FILE_IO is true.

Constructor Summary

Constructors

Constructor	Description
S3FileIOAdapter()

Method Summary

Modifier and Type	Method	Description
protected SeekableChannelsProvider	createProviderImpl(@NotNull String uriScheme, @NotNull org.apache.iceberg.io.FileIO io, @Nullable Object specialInstructions)
boolean	isCompatible(@NotNull String uriScheme, @NotNull Class<?> ioClass)	Check if this adapter is compatible with the given URI scheme and file IO of the given class.
boolean	isCompatible(@NotNull String uriScheme, @NotNull org.apache.iceberg.io.FileIO io)	Check if this adapter is compatible with the given URI scheme and file IO.

Methods inherited from class io.deephaven.iceberg.util.FileIOAdapterBase

createProvider

Methods inherited from class java.lang.Object

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

Constructor Details

S3FileIOAdapter

public S3FileIOAdapter()

Method Details

isCompatible

public boolean isCompatible(@NotNull
 @NotNull String uriScheme,
 @NotNull
 @NotNull org.apache.iceberg.io.FileIO io)

Description copied from interface: FileIOAdapter

Check if this adapter is compatible with the given URI scheme and file IO.

isCompatible

public boolean isCompatible(@NotNull
 @NotNull String uriScheme,
 @NotNull
 @NotNull Class<?> ioClass)

Description copied from interface: FileIOAdapter

Check if this adapter is compatible with the given URI scheme and file IO of the given class.

createProviderImpl

protected SeekableChannelsProvider createProviderImpl(@NotNull
 @NotNull String uriScheme,
 @NotNull
 @NotNull org.apache.iceberg.io.FileIO io,
 @Nullable
 @Nullable Object specialInstructions)

Specified by:

createProviderImpl in class FileIOAdapterBase