Package io.delta.kernel.defaults.engine.hadoopio

Class HadoopInputFile

Object
io.delta.kernel.defaults.engine.hadoopio.HadoopInputFile
All Implemented Interfaces:
InputFile
public class HadoopInputFile extends Object implements InputFile

  • Constructor Details

    • HadoopInputFile

      public HadoopInputFile(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, long fileSize)

  • Method Details

    • length

      public long length() throws IOException
      Description copied from interface: InputFile
      Get the size of the file.
      Specified by:
      length in interface InputFile
      Returns:
      the size of the file.
      Throws:
      IOException

    • path

      public String path()
      Description copied from interface: InputFile
      Get the path of the file.
      Specified by:
      path in interface InputFile
      Returns:
      the path of the file.

    • newStream

      public SeekableInputStream newStream() throws IOException
      Description copied from interface: InputFile
      Get the input stream to read the file.
      Specified by:
      newStream in interface InputFile
      Returns:
      the input stream to read the file. It is the responsibility of the caller to close the stream.
      Throws:
      IOException