Package io.deephaven.iceberg.util

Class FileIOAdapterBase

java.lang.Object

io.deephaven.iceberg.util.FileIOAdapterBase

All Implemented Interfaces:

FileIOAdapter

Direct Known Subclasses:

GCSFileIOAdapter, LocalFileIOAdapter, S3FallbackFileIOAdapter, S3FileIOAdapter

public abstract class FileIOAdapterBase
extends Object
implements FileIOAdapter

Constructor Summary

Constructors

Constructor	Description
FileIOAdapterBase()

Method Summary

Modifier and Type	Method	Description
final SeekableChannelsProvider	createProvider(@NotNull String uriScheme, @NotNull org.apache.iceberg.io.FileIO io, @Nullable Object object)	Create a new SeekableChannelsProvider compatible for reading from and writing to the given URI scheme using the given FileIO implementation.
protected abstract SeekableChannelsProvider	createProviderImpl(@NotNull String uriScheme, @NotNull org.apache.iceberg.io.FileIO io, @Nullable Object specialInstructions)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.deephaven.iceberg.util.FileIOAdapter

isCompatible, isCompatible

Constructor Details

FileIOAdapterBase

public FileIOAdapterBase()

Method Details

createProvider

public final SeekableChannelsProvider createProvider(@NotNull
 @NotNull String uriScheme,
 @NotNull
 @NotNull org.apache.iceberg.io.FileIO io,
 @Nullable
 @Nullable Object object)

Description copied from interface: FileIOAdapter

Create a new SeekableChannelsProvider compatible for reading from and writing to the given URI scheme using the given FileIO implementation. For example, for an "s3" URI, we will create a SeekableChannelsProvider which can read files from S3.

Specified by:

createProvider in interface FileIOAdapter

Parameters:

uriScheme - The URI scheme

io - The FileIO implementation to use.

object - An optional object to pass special instructions to the provider.

createProviderImpl

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