org.apache.pig.piggybank.storage.avro
Class AvroStorageInputStream

java.lang.Object
  extended by org.apache.pig.piggybank.storage.avro.AvroStorageInputStream
All Implemented Interfaces:
Closeable, org.apache.avro.file.SeekableInput

public class AvroStorageInputStream
extends Object
implements Closeable, org.apache.avro.file.SeekableInput

Adapt an FSDataInputStream to SeekableInput.


Constructor Summary
AvroStorageInputStream(org.apache.hadoop.fs.Path path, org.apache.hadoop.mapreduce.TaskAttemptContext context)
          Construct given a path and a configuration.
 
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

AvroStorageInputStream

public AvroStorageInputStream(org.apache.hadoop.fs.Path path,
                              org.apache.hadoop.mapreduce.TaskAttemptContext context)
                       throws IOException
Construct given a path and a configuration.

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 © 2007-2012 The Apache Software Foundation