Class FsInput

java.lang.Object
org.apache.avro.mapred.FsInput
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.avro.file.SeekableInput

public class FsInput extends Object implements Closeable, org.apache.avro.file.SeekableInput
Adapt an FSDataInputStream to SeekableInput.
  • Constructor Details

  • Method Details

    • length

      public long length()
      Specified by:
      length in interface org.apache.avro.file.SeekableInput
    • read

      public int read(byte[] b, int off, int len) throws IOException
      Specified by:
      read in interface org.apache.avro.file.SeekableInput
      Throws:
      IOException
    • seek

      public void seek(long p) throws IOException
      Specified by:
      seek in interface org.apache.avro.file.SeekableInput
      Throws:
      IOException
    • tell

      public long tell() throws IOException
      Specified by:
      tell in interface org.apache.avro.file.SeekableInput
      Throws:
      IOException
    • close

      public void close() throws IOException
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Throws:
      IOException