Class HadoopInput

java.lang.Object
org.apache.trevni.avro.HadoopInput
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.trevni.Input

public class HadoopInput extends Object implements org.apache.trevni.Input
Adapt a Hadoop FSDataInputStream to Trevni's Input.
  • Constructor Details

  • Method Details

    • length

      public long length()
      Specified by:
      length in interface org.apache.trevni.Input
    • read

      public int read(long p, byte[] b, int s, int l) throws IOException
      Specified by:
      read in interface org.apache.trevni.Input
      Throws:
      IOException
    • close

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