Package io.deephaven.iceberg.relative

Class RelativeFileIO

java.lang.Object
io.deephaven.iceberg.relative.RelativeFileIO
All Implemented Interfaces:
Closeable, Serializable, AutoCloseable, org.apache.hadoop.conf.Configurable, org.apache.iceberg.hadoop.HadoopConfigurable, org.apache.iceberg.io.DelegateFileIO, org.apache.iceberg.io.FileIO, org.apache.iceberg.io.SupportsBulkOperations, org.apache.iceberg.io.SupportsPrefixOperations
@VisibleForTesting public final class RelativeFileIO extends Object implements org.apache.iceberg.hadoop.HadoopConfigurable, org.apache.iceberg.io.DelegateFileIO
While this class is in the public source set, it is meant to support testing use cases only and should not be used in production.
See Also:

  • Field Details

    • BASE_PATH

      public static final String BASE_PATH

    • IO_IMPL

      public static final String IO_IMPL

    • IO_DEFAULT_IMPL

      public static final String IO_DEFAULT_IMPL

  • Constructor Details

    • RelativeFileIO

      public RelativeFileIO()

    • RelativeFileIO

      public RelativeFileIO(org.apache.hadoop.conf.Configuration hadoopConf)

    • RelativeFileIO

      public RelativeFileIO(org.apache.iceberg.util.SerializableSupplier<org.apache.hadoop.conf.Configuration> hadoopConf)

  • Method Details

    • getConf

      public org.apache.hadoop.conf.Configuration getConf()
      Specified by:
      getConf in interface org.apache.hadoop.conf.Configurable

    • setConf

      public void setConf(org.apache.hadoop.conf.Configuration conf)
      Specified by:
      setConf in interface org.apache.hadoop.conf.Configurable

    • serializeConfWith

      public void serializeConfWith(Function<org.apache.hadoop.conf.Configuration,org.apache.iceberg.util.SerializableSupplier<org.apache.hadoop.conf.Configuration>> confSerializer)
      Specified by:
      serializeConfWith in interface org.apache.iceberg.hadoop.HadoopConfigurable

    • absoluteLocation

      public String absoluteLocation(String location)

    • initialize

      public void initialize(Map<String,String> properties)
      Specified by:
      initialize in interface org.apache.iceberg.io.FileIO

    • properties

      public Map<String,String> properties()
      Specified by:
      properties in interface org.apache.iceberg.io.FileIO

    • newInputFile

      public org.apache.iceberg.io.InputFile newInputFile(String path)
      Specified by:
      newInputFile in interface org.apache.iceberg.io.FileIO

    • newInputFile

      public org.apache.iceberg.io.InputFile newInputFile(String path, long length)
      Specified by:
      newInputFile in interface org.apache.iceberg.io.FileIO

    • newOutputFile

      public org.apache.iceberg.io.OutputFile newOutputFile(String path)
      Specified by:
      newOutputFile in interface org.apache.iceberg.io.FileIO

    • deleteFiles

      public void deleteFiles(Iterable<String> iterable) throws org.apache.iceberg.io.BulkDeletionFailureException
      Specified by:
      deleteFiles in interface org.apache.iceberg.io.SupportsBulkOperations
      Throws:
      org.apache.iceberg.io.BulkDeletionFailureException

    • listPrefix

      public Iterable<org.apache.iceberg.io.FileInfo> listPrefix(String s)
      Specified by:
      listPrefix in interface org.apache.iceberg.io.SupportsPrefixOperations

    • deletePrefix

      public void deletePrefix(String s)
      Specified by:
      deletePrefix in interface org.apache.iceberg.io.SupportsPrefixOperations

    • deleteFile

      public void deleteFile(String path)
      Specified by:
      deleteFile in interface org.apache.iceberg.io.FileIO

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Specified by:
      close in interface org.apache.iceberg.io.FileIO