org.apache.hadoop.fs
Class AvroFSInput

java.lang.Object
  extended by org.apache.hadoop.fs.AvroFSInput
All Implemented Interfaces:
Closeable, org.apache.avro.file.SeekableInput

@InterfaceAudience.Public
@InterfaceStability.Stable
public class AvroFSInput
extends Object
implements Closeable, org.apache.avro.file.SeekableInput

Adapts an FSDataInputStream to Avro's SeekableInput interface.


Constructor Summary
AvroFSInput(FileContext fc, Path p)
          Construct given a FileContext and a Path.
AvroFSInput(FSDataInputStream in, long len)
          Construct given an FSDataInputStream and its length.
 
Method Summary
 void close()
           
 long length()
           
 int read(byte[] b, int off, int len)
           
 void seek(long p)
           
 long tell()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AvroFSInput

public AvroFSInput(FSDataInputStream in,
                   long len)
Construct given an FSDataInputStream and its length.


AvroFSInput

public AvroFSInput(FileContext fc,
                   Path p)
            throws IOException
Construct given a FileContext and a Path.

Throws:
IOException
Method Detail

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 Closeable
Throws:
IOException


Copyright © 2014 Apache Software Foundation. All Rights Reserved.